1 在算子上设置
inputstream.flatmap(-.split(" ")).setParallelism(3)
2 在上下文环境上设置
StreamExecutionEnvironment.getExecutionEnvironment.setParallelism(5)
3 clinet 提交job时设置
flink run -c com.my.wordcout -p
4 在flink_config.yml 中设置
parallism.default:1
四种设置方式优先级依次递减

1 在算子上设置
inputstream.flatmap(-.split(" ")).setParallelism(3)
2 在上下文环境上设置
StreamExecutionEnvironment.getExecutionEnvironment.setParallelism(5)
3 clinet 提交job时设置
flink run -c com.my.wordcout -p
4 在flink_config.yml 中设置
parallism.default:1
四种设置方式优先级依次递减