当前位置: 首页 > 知识库问答 >
问题:

在库伯内特斯的多个任务管理器上未安排Apache Flink作业(副本)

应煌
2023-03-14

我有一个简单的Flink作业,从ActiveMQ源读取

当我看到Flink仪表板时,我看到此作业仅在一个TaskManager中运行,而另一个TaskManager中没有作业。我通过检查计划中的每个操作员来验证这一点,也在任务管理器的UI页面中,管理器的第一页有所有可用插槽。我附上以下图片以供参考。

我配置错了吗?我的理解差距在哪里?有人能解释一下吗?

共有1个答案

隆睿
2023-03-14

第一个任务管理器有足够的槽(10)来完全满足你工作的要求。

调度器的默认行为是在使用另一个任务管理器的插槽之前,先充分利用一个任务管理器的插槽。如果您希望Flink将工作负载分散到所有可用的任务管理器中,请设置集群。均匀分布的插槽:在flink-conf.yaml中为true。(在Flink 1.10中添加了此选项,以重新创建类似于Flink 1.5之前默认设置的调度行为。)

 类似资料:
  • 据我所知,作业对象应该在一定时间后收获豆荚。但是在我的GKE集群(库伯内特斯1.1.8)上,“kubectl get pods-a”似乎可以列出几天前的豆荚。 所有这些都是使用乔布斯API创建的。 我确实注意到在使用 kubectl 删除作业后,pod 也被删除了。 我在这里主要担心的是,我将在批量作业中在集群上运行成千上万个pod,并且不想让内部待办系统过载。

  • 我在AKS上部署了Kubernetes 1.8.7集群。我正在尝试使用帮助安装NGINX入口控制器(helm install stable/NGINX入口——名称空间kube系统)。I init helm使用helm init——服务帐户默认值。我遇到以下错误 错误:release my release失败:clusterroles.rbac.authorization.k8s。io“my rel

  • 我打算有一个带有Jenkins的光盘管道,它接受我的应用程序,将码头工人映像发布到我的私人码头工人存储库。我想我知道怎么做。 我不确定的是库伯内特斯部分。我想把那个图像部署到我的私人库伯内特斯集群(目前是1个主集群) 问:安装了 kubectl 和 docker 的詹金斯从站是否需要成为 Kubernetes 集群的一部分才能触发部署?如何触发该部署?

  • 我在windows 10中创建了两个在我的minikube环境中运行的POD。一个POD带有Spring boot应用程序容器,另一个POD带有mysql容器。对于Spring boot应用程序,服务类型为nodePort,对于MYSQL pod,服务类型为club sterIP。这意味着Mysql pod只需要在集群内部进行通信。但是对于Spring boot应用程序,需要从浏览器访问,所以我配

  • 库伯内特斯top(kubectl top)命令显示的内存使用情况与pod中运行Linuxtop命令不同。 我创建了 k8s 部署,其中 YAML 包含以下内存限制: 以下命令的输出如下所示: 运行linux top命令: 注意“free -g”还显示使用了11Gb。 问题是这与“kubectl顶部”相矛盾,后者仅显示使用了1205 mb。