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


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

回复