tongchenkeji 发表于：2023-12-18 8:06:190次点击 已关注取消关注 关注 私信 flink sql 现在是不是能给算子单独调整并行度了啊？[阿里云] 暂停朗读为您朗读 flink sql 现在是不是能给算子单独调整并行度了啊？ 「点点赞赏，手留余香」 赞赏 还没有人赞赏，快来当第一个赞赏的人吧！ 海报 阿里云# SQL1285# 实时计算 Flink版3179# 流计算2236
小周sirAM 2023-12-21 7:17:59 1 是的，Flink SQL可以给算子单独调整并行度。具体来说，有两种主要方式可以进行设置： 在Flink Web UI中进行调整：你可以找到对应的Flink Job，点击进入Job的详情页，然后在任务算子的后面找到“并行度”一栏，点击“Edit”按钮，即可修改并行度参数。 在代码中进行设置：可以在算子后跟着调用setParallelism()方法，来设置当前算子的并行度。这种方式设置的并行度，只针对当前算子有效。
是的，Flink SQL可以给算子单独调整并行度。具体来说，有两种主要方式可以进行设置：
在Flink Web UI中进行调整：你可以找到对应的Flink Job，点击进入Job的详情页，然后在任务算子的后面找到“并行度”一栏，点击“Edit”按钮，即可修改并行度参数。
在代码中进行设置：可以在算子后跟着调用setParallelism()方法，来设置当前算子的并行度。这种方式设置的并行度，只针对当前算子有效。
no ，此回答整理自钉群“【③群】Apache Flink China社区”
Flink SQL并不直接支持为每个算子单独设置并行度。在Flink SQL中，通常是在创建表或执行作业时指定一个全局的并行度。