大家好，我是考100分的小小码 ，祝大家学习进步，加薪顺利呀。今天说一说flink 并行度和分区的关系_flink并行度,希望您对编程的造诣更进一步.
-
代码中设置
setParallelism()-
全局设置：
env.setParallelism(3);代码100分
-
算子设置（部分设置）：
代码100分sum(1).setParallelism(3)
-
-
客户端CLI设置：
./bin/flink run -p 3 -
修改配置文件设置
/conf/flink-conf.yaml的parallelism.defaul数值 -
-
全局设置：
代码100分env.setMaxParallelism(n) -
算子设置（部分设置）：
sum(1).setMaxParallelism(n)默认的最大并行度是近似于operatorParallelism + (operatorParallelism / 2)，下限是127，上线是32768.
执行顺序级别：算子>全局env>CLI>配置文件 。
.setParallelism()的并行度需要小于.setMaxParallelism()的最大并行度。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
转载请注明出处: https://daima100.com/9468.html
