Flink的setparallelism 和setmaxparallelism有啥区别吗？-[阿里云_云淘科技]

匿名 • 2023年12月25日上午8:07 • 阿里云

Flink的setparallelism 和setmaxparallelism有啥区别吗？

以下为热心网友提供的参考意见

前者是实际执行的并行度。后者是理论最大并行度默认128
https://blog.csdn.net/qq_21383435/article/details/126441252?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522170315374416800226592154%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=170315374416800226592154&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-2-126441252-null-null.nonecase&utm_term=%E6%9C%80%E5%A4%A7%E5%B9%B6%E8%A1%8C%E5%BA%A6&spm=1018.2226.3001.4450 ，此回答整理自钉群“【③群】Apache Flink China社区”

以下为热心网友提供的参考意见

在Flink中，setParallelism和setMaxParallelism都是用来设置算子并行度的，但它们的作用和用途不同。

setParallelism：这个方法用于设置算子的并行度。并行度是指一个算子可以同时运行的实例数量。设置并行度可以影响任务的执行速度和资源使用。
setMaxParallelism：这个方法用于设置算子的最大并行度。最大并行度是一个算子可以支持的最大并行度，它限制了算子可以扩展到的最大并行度。设置最大并行度可以防止算子过度扩展，导致资源浪费和性能下降。

总的来说，setParallelism用于设置算子的当前并行度，而setMaxParallelism用于设置算子的最大并行度。在实际使用中，可以根据任务的特性和资源使用情况来合理设置这两个参数。

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/18639.html