You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "penguin." <bx...@126.com> on 2021/05/17 08:10:36 UTC

hibench使用identity程序测试flink

根据介绍,identity是从kafka中读取数据,然后写回kafka。
在使用hibench中的identity程序对flink进行测试时,在hibench的conf目录下的flink.conf文件中将并行度设置为20。
提交任务后,在ui界面上发现只有一个子任务,即只有一个节点的一个slot中被分配了任务。请问如何在使用identity测试flink时,能有多个子任务呢?


(好像每次放图片都无法显示,就没有提供截图了)