代码中设置setParallelism()
全局设置:
env.setParallelism(3);
算子设置(部分设置):
sum(1).setParallelism(3)
客户端CLI设置(或webui直接输入数量):
./bin/flink run -p 3
系统设置:
修改配置文件设置/conf/flink-conf.yaml的parallelism.defaul数值
全局设置:
env.setMaxParallelism(n)
算子设置(部分设置):
sum(1).setMaxParallelism(n)
默认的最大并行度是近似于operatorParallelism + (operatorParallelism / 2),下限是127,上线是32768.
Flink并行度配置级别:算子>全局env>客户端CLI>配置文件 。
注意:
联系客服