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
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。