flink批模式提高并行度,发现不管怎么调参数,并行度都是1,怎么解决这个问题?[阿里云实时计算 Flink版]

flink批模式提高并行度,发现不管怎么调参数,并行度都是1,怎么解决这个问题?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 在阿里云实时计算 Flink 版中,Flink 批模式的并行度可以通过以下两种方式进行设置:

    1. 通过 SQL 编辑器的“高级参数”进行设置

    在 SQL 编辑器中,可以选择“高级参数”选项,然后找到“执行配置”中的“并行度”设置,将其设置为期望的并行度即可。这种方式比较简单,适合对并行度调优要求不高的场景。

    1. 修改 Flink 任务的配置文件

    阿里云实时计算 Flink 版允许通过“配置管理”模块对 Flink 任务的配置进行修改。通过在 flink-conf.yaml 文件中添加如下配置,可以在任务运行时指定默认并行度:

    parallelism.default: ${job_parallelism}

    其中,${job_parallelism}需要设置一个具体的整数值,表示任务默认的并行度。

  2. 有的算子会限制是1,看看你算子的实现或者组件的源码,此回答整理自钉群“【③群】Apache Flink China社区”