【kubernetes】The LocalStreamEnvironment cannot be used when submitting

时间：2024-08-24 10:25:12浏览次数：12

标签：used kubernetes flink when LocalStreamEnvironment cannot

在这里插入图片描述

1.概述

新手上路，首先参考文章：【Flink】Mac下使用flink-kubernetes-operator本地运行flink程序在这个文章中，我们知道了如何使用demo提交flink任务。

但是如果我们的机器没有kubectl命令，我们改怎么提交任务到flink呢？

这里我们可以使用代码提交，此处文章参考：【kubernetes】使用flink-kubernetes-operator、使用java代码提交任务到flink

其实在这个之前，我也做了一次实验，然后本次实验是出问题了，导致任务一直报错：The LocalStreamEnvironment cannot be used when submitting a program through a client, or running in a TestEnvironment context.

Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: The LocalStreamEnvironment cannot be used when submitting a p

标签：used,kubernetes,flink,when,LocalStreamEnvironment,cannot
From： https://blog.csdn.net/qq_21383435/article/details/134427513

D10 kubernetes 容器监控检查之探针
0、简介》当pod状态显示为running，这表明pod中所有容器都已经运行，但这并不意味着pod中的应用程序已经准备好提供服务。实际上，running状态仅仅表示容器的启动状态，与应用程序是否准备好提供服务没有直接关系。可能由于以下原因，应用程序不能提供服务：-应用程序启动慢：容器已运行，但容......
D9 kubernetes 之pod中声明端口
》在pod配置中，ports字段用于定义容器公开的端口列表。该字段的值是一个对象列表类型，其中每个元素（对象）对应一个端口规则，每个端口规则由以下字段组成。name：端口名称。仅定义一个端口时，该字段可选containerPort：容器端口，容器内应用程序监听的端口protocol：端口使用的协议：TCP、UDP、......
D7 kubernetes 容器运行命令与参数
》在pod配置中，command和args字段用于定义容器的命令和参数1、command》 command字段用于定义容器启动时要执行的命令，并覆盖镜像中默认的启动命令。它的值是一个字符串列表类型，其中第一个元素视为命令名称，后续元素视为命令的参数command配置实例如下[root@k8s-masterk8s]#......
D6 kubernetes 中pod 常用命令
常用的pod管理命令#创建一个podkubectlrunpod名称--image=镜像地址#查看当前命名空间中的pod对象kubectlgetpods#查看指定命名空间中的pod对象kubectlgetpods-n命名空间#查看所有命名空间中的podkubectlgetpods-A#查看pod中容器的日志，默认来自第......
D5 kubernetes 中pod资源常见字段及值类型(yaml)
》pod资源包含许多配置字段，以提供更多的功能。以下是一些常见的配置字段和作用apiVersion:v1#api版本king:Pod#资源类型metadata:<Object>#资源元数据lables:......
Kubernetes 1.28.2 负载均衡解决方案 MetalLB实践
MetalLB是一个用于在Kubernetes集群中提供外部IP地址的负载均衡器实现。安装须知：Kubernetesv1.13.0或者更新的版本规划IPv4地址给MetalLB用于分配。当使用BGP操作模式时，你将需要一个或多个能够支持BGP协议的路由器。L2模式下需要各个节点间7946端口(TCP&......
MybatisPlus Caused by: org.apache.ibatis.builder.BuilderException: Error evalua
报错信息：org.mybatis.spring.MyBatisSystemException:nullatorg.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:97)atorg.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessi......
Kubernetes: client-go 源码剖析（一）
kubernetes:client-go 系列文章：Kubernetes:client-go源码剖析（一）Kubernetes:client-go源码剖析（二）0.前言在看 kube-scheduler 组件的过程中遇到了 kube-scheduler 对于 client-go 的调用，泛泛的理解调用过程总有种隔靴搔痒的感觉，于是调转头先把 client-go 理清楚......
nextjs 客户端图片因跨域 strict-origin-when-cross-origin 无法展示
使用next.config.js配置跨域规则Next.js提供了一个配置文件next.config.js，你可以在其中配置images选项，以允许跨域加载图片。在Next.js中，remotePatterns配置用于定义允许加载远程图像的域名及路径。不过，remotePatterns并不支持传统的正则表达式，而是使用类似正则表达式......
Fedora Linux 41 推出多版本 Kubernetes RPM，灵活性大大增加！
随着FedoraLinux41的即将发布，Kubernetes管理员和企业用户将迎来一个令人振奋的功能更新：多版本KubernetesRPM。这一创新举措标志着Fedora在Kubernetes打包策略上的重大转变，为容器化环境提供了更大的灵活性和控制能力。在容器化技术日益普及的今天，Kubernetes已......

【kubernetes】The LocalStreamEnvironment cannot be used when submitting

1.概述

相关文章

赞助商

阅读排行