tongchenkeji 发表于:2023-4-19 16:28:460次点击 已关注取消关注 关注 私信 flink批模式提高并行度,发现不管怎么调参数,并行度都是1,怎么解决这个问题?[阿里云实时计算 Flink版] 暂停朗读为您朗读 flink批模式提高并行度,发现不管怎么调参数,并行度都是1,怎么解决这个问题? 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# 实时计算 Flink版3179# 流计算2236
wljslmzAM 2023-11-27 18:11:41 1 在阿里云实时计算 Flink 版中,Flink 批模式的并行度可以通过以下两种方式进行设置: 通过 SQL 编辑器的“高级参数”进行设置 在 SQL 编辑器中,可以选择“高级参数”选项,然后找到“执行配置”中的“并行度”设置,将其设置为期望的并行度即可。这种方式比较简单,适合对并行度调优要求不高的场景。 修改 Flink 任务的配置文件 阿里云实时计算 Flink 版允许通过“配置管理”模块对 Flink 任务的配置进行修改。通过在 flink-conf.yaml 文件中添加如下配置,可以在任务运行时指定默认并行度: parallelism.default: ${job_parallelism} 其中,${job_parallelism}需要设置一个具体的整数值,表示任务默认的并行度。
在阿里云实时计算 Flink 版中,Flink 批模式的并行度可以通过以下两种方式进行设置:
在 SQL 编辑器中,可以选择“高级参数”选项,然后找到“执行配置”中的“并行度”设置,将其设置为期望的并行度即可。这种方式比较简单,适合对并行度调优要求不高的场景。
阿里云实时计算 Flink 版允许通过“配置管理”模块对 Flink 任务的配置进行修改。通过在 flink-conf.yaml 文件中添加如下配置,可以在任务运行时指定默认并行度:
其中,
${job_parallelism}
需要设置一个具体的整数值,表示任务默认的并行度。有的算子会限制是1,看看你算子的实现或者组件的源码,此回答整理自钉群“【③群】Apache Flink China社区”