1, 从socket流中读取数据并行度只能是 1
//从socket文本流读取数据
DataStream<String> inputDataStream = env.socketTextStream(host, port);
2, 特定的算子设定了并行度最优先
//基于数据流进行转换计算
DataStream<Tuple2<String, Integer>> resultStream = inputDataStream.flatMap(new MyFlatMapper()).keyBy(0).sum(1).setParallelism(2);
其中keyBy(0)不是算子, 只是一个hash分配作用, 所以它不能设置并行度
3, 算子没有设定并行度就是用整体运行环境设置的并行度
//创建流处理执行环境
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(1);
4, 环境的并行度没有设置就使用提交时候提交参数设置的并行度
5, 最后都没有设置就遵循 flink的配置文件
parallelism.default: 1