Flink中并行度相关问题

Posted laogou-idea

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink中并行度相关问题相关的知识,希望对你有一定的参考价值。

Flink运行模式分为:集群模式、单机模式

集群模式:Flink的并行度取决于配置文件中的默认值,如下如所示:

技术图片

在此配置的默认值下,全局的所有算子平行度都是1,我们也可以在程序中重写这个并行度 设置方式如下:

技术图片

 

在本地模式下:默认的并行度为CPU核数可以执行线程数的最大值。比如:一台 8核 16线程的pc ,默认的并行度就是16,我们同样在程序内可以设置重写并行度,重写方式同集群模式

 

以上是关于Flink中并行度相关问题的主要内容,如果未能解决你的问题,请参考以下文章

flink 并行度

Spark 并行度

Flink并行度

Flink并行度

合理评估flink的并行度

Flink并行度可以有如下几种指定方式