所有的taskmanager都在一台节点上运行

[pass Li]

程序是消费kafka某个topic的数据到另外一个topic中

提交命令如下：./bin/flink run -m yarn-cluster -ys 2 -yjm 2048 -ytm 4096 --parallelism=8...

我想让这四个taskmanager分配到多个节点上，但是最终都在一个节点上运行，希望有大佬帮忙指点下

如图：所有的taskmanager都运行在cdh3上

---

[hidden email]