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

[liya...@huimin100.cn]

程序是消费kafka某个topic的数据到另外一个topic中
提交命令如下：./bin/flink run -m yarn-cluster -ys 2 -yjm 2048 -ytm 4096 
--parallelism=8...
我想让这四个taskmanager分配到多个节点上，但是最终都在一个节点上运行，希望有大佬帮忙指点下


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


liya...@huimin100.cn