在kubernetes上执行flink任务

cgyqldqp  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(255)

我正在kubernetes上试用Flink1.5的最新版本。
flink on kubernetes文档定义了如何部署flink,我在mac中使用了minikube。flinkui很好地显示了作业管理器和任务管理器。
我的问题是如何在上面的flink集群上运行一个示例应用程序。flink示例项目提供了如何使用flink应用程序构建docker映像并将该应用程序提交给flink的信息。我仿效了这个例子,把flink的版本改成了最新版本。我发现应用程序(示例应用程序)提交成功,并在kubernetes的pod中显示,但flinkui没有显示任何正在运行的作业。有人能给我举一个例子,说明如何向运行在kubernetes上的flink集群提交一个flink作业。

yhxst69z

yhxst69z1#

minikube的vm有一个问题,pod不能引用指向自身的服务。这是相应的问题。
您必须登录minikube vm才能设置正确的 ip link . 下面的命令应该可以做到这一点

minikube ssh 'sudo ip link set docker0 promisc on'

我们之所以需要这样做,是因为在集群入口点上运行的web提交处理程序需要连接到集群入口点才能提交作业。

相关问题