正在kubernetes上运行flink作业
我正在kubernetes上试用最新版本的Flink1.5的flink工作。
我的问题是如何在上面的flink集群上运行一个示例应用程序。flink示例项目提供了如何使用flink应用程序构建docker映像并将该应用程序提交给flink的信息。我遵循了这个例子，只是把flink的版本改成了最新版本。我发现应用程序（example-app）提交成功，并且在kubernetes的pod中显示，但是flink UI没有显示任何正在运行的作业。有人能给我指出一个如何向运行在Kubernetes上的flink集群提交flink作业的例子吗。
共有1个答案
MiniKube的VM存在一个问题，pod无法引用指向自身的服务。这里是相应的问题。
您必须登录到Minikube VM以设置正确的IP链接。下面的命令应该起作用
minikube ssh 'sudo ip link set docker0 promisc on'
之所以需要这样做，是因为运行在集群入口点上的web提交处理程序需要连接到集群入口点以提交作业。
-
我已经安装了火花图表在我的k8s集群掌舵，我有3个豆荚运行1个主和2个执行，但仍然能够提交火花作业...在“提交应用程序”一节https://github.com/bitnami/charts/tree/master/bitnami/spark中提到我们可以使用。/bin/spark-submit--class org.apache.spark.examples.sparkpi--master s
-
我们正在使用构建流处理作业，并计划在库伯内特斯集群上运行它。在参考官方Flink留档时，我们主要遇到了两种将Flink作业提交到库伯内特斯集群的方法，一种是模式，另一种是模式。我们注意到使用后一种选项，没有yaml配置文件，看起来很简单。只是想知道推荐的模式/方法是什么以及它们的优缺点。谢谢。
-
我刚刚尝试在Apple Mac Pro上运行Apache Flink的基本示例，新的M1处理器使用Rosetta 2兼容层。 不幸的是，它在以下堆栈跟踪中失败： 所以我的问题是，有人让它运行了吗？有可能在苹果硅上执行Flink工作吗？ 编辑（13.04.2021）顺便说一句：使用Rosetta兼容层运行时发生此错误。因此，不幸的是，这并不能解决当前的问题。 编辑（2021年4月14日，回应理查德·
-
我们正在hadoop 2.6集群上运行Flink 1.5.0纱线会话/料仓/纱线会话。但是，这不会启动任何TaskManager。日志显示Flink JobManager以领导者id 000000开始。。。在JobManager web界面中也没有任务管理器。当我们向这个jobManager提交flink作业时，一些TaskManManager会在执行作业的web界面上生成。这是Flink1.5.
-
这是关于一个flink作业，它有一个简单的源来从url中获取数据，然后过滤数据，然后在一个进程函数中收集数据一段时间（keyBy），最后在一个映射中处理收集到的数据。由于某些原因，即使flinkUI显示它正在运行，作业在几天后也会停止运行。有没有办法知道为什么会有这样的行为，也有没有办法知道一个作业实际上是否已经停止，即使UI显示它正在运行。 附言：我怎么知道工作已经停止了？？答：它没有执行它正在
-
当Flink在Kubernetes作为豆荚运行时，有人知道如何用Flink运行梁Python管道吗？ 我已经成功地使用Portable runner和指向运行在Docker容器中的本地Flink服务器的作业服务运行了一个Beam Python管道。 是否有一种方法可以部署一个侧容器并使用不同的工厂来运行Python harness流程？正确的做法是什么？ 这是DockerEnvironmentFa