当前位置： 移动技术网 > IT编程>数据库>其他数据库 > Flink设置并行度的方式和执行级别

Flink设置并行度的方式和执行级别

2020年03月18日  | 移动技术网IT编程  | 我要评论

flink设置并行度的几种方式

  1. 代码中设置setparallelism()

    • 全局设置：

      env.setparallelism(3);　

    • 算子设置（部分设置）：

      sum(1).setparallelism(3)

  2. 客户端cli设置：

    ./bin/flink run -p 3

  3.  修改配置文件设置/conf/flink-conf.yaml的parallelism.defaul数值

  4. 最大并行度设置

    • 全局设置：

      env.setmaxparallelism(n)　

    • 算子设置（部分设置）：

      sum(1).setmaxparallelism(n)

      默认的最大并行度是近似于operatorparallelism + (operatorparallelism / 2)，下限是127，上线是32768. 

执行顺序级别：算子>全局env>cli>配置文件 。

.setparallelism()的并行度需要小于.setmaxparallelism()的最大并行度。

 

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网