1 个回答
Flink并行度根据任务设置:
1、常规任务:Source,Transform,Sink算子都与Kafka分区保持一致
2、计算偏大任务:Source,Sink算子与Kafka分区保持一致,Transform算子可设置成2的n次方,64,128…发布于:11个月前 (02-06) IP属地:四川省
我来回答
您需要 登录 后回答此问题!
