我在跟踪这份文件
关于如何使用minikube设置独立的kubernetes会话集群。我已经安装了迷你库,我可以制作吊舱。在flink-configuration-configmap.yaml文件中,我设置了
taskmanager.numberOfTaskSlots: 4
parallelism.default: 2从Flink仪表板正确读取此属性:

但是,当我提交Flink作业时,所有任务都与1具有并行性:

我想指出的是,任务应该具有并行性。
你能帮我弄清楚怎么回事吗?谢谢。
发布于 2022-01-18 10:54:47
默认的并行性可以在提交期间或由作业本身重写。我会在这些地方查看并行性是否被显式设置。
https://stackoverflow.com/questions/70754110
复制相似问题