A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

  • 代码中设置setParallelism()
    • 全局设置:
      [size=1em]
      1

      env.setParallelism(3); 



    • 算子设置(部分设置):
      [size=1em]
      1

      sum(1).setParallelism(3)




  • 客户端CLI设置:
    [size=1em]
    1

    ./bin/flink run -p 3



  • 修改配置文件设置/conf/flink-conf.yaml的parallelism.defaul数值
  • 最大并行度设置

    • 全局设置:
      [size=1em]
      1

      env.setMaxParallelism(n) 



    • 算子设置(部分设置):
      [size=1em]
      1

      sum(1).setMaxParallelism(n)



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

执行顺序级别:算子>全局env>CLI>配置文件 。
.setParallelism()的并行度需要小于.setMaxParallelism()的最大并行度。

0 个回复

您需要登录后才可以回帖 登录 | 加入黑马