0
回答
flink 只把任务提交到一个taskManager
科大讯飞通用文字识别100000次/天免费使用。立即申请   

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

各位好:刚开始学习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的数据,提高计算的并行度,要怎么实现呢?

谢谢

<无标签>
举报
刘朕
发帖于5个月前 0回/24阅
顶部