返回

提问 添加收藏

flink 只把任务提交到一个taskManager

刘朕 发布于 2018年01月13日 (共有0个回帖)

@阿里云官方博客 你好,想跟你请教个问题:

各位好:刚开始学习flink,有个问题请教:

 我搭建了有5个节点的flink集群(standalone 模式),主要代码逻辑为:通过flink消费kafka的数据,完成一段业务逻辑的计算,打包在服务器上master提交后,任务只在一个节点上运行,

执行命令如下:

./flink run -p 10 -d -c com.gennlife.FlinkApplicationStarter ../../rws-streaming-flink.jar --zk.connection.urls 10.0.2.17:2181,10.0.2.18:2181,10.0.2.79:2181 --kafka.brokers 10.0.2.17:9092,10.0.218:9092  --group.id testflink --topic flinktest2

      我希望任务可以被分配到多个节点,也就是在多个节点上同时消费Kafka的数据,提高计算的并行度,要怎么实现呢?

谢谢

文明上网,理性发言
客户端 Android iPhone WP7