tongchenkeji 发表于:2023-2-7 14:38:500次点击 已关注取消关注 关注 私信 flinksql中,如何给每个节点设置单独的并行度?[阿里云实时计算 Flink版] 暂停朗读为您朗读 flinksql中,如何给每个节点设置单独的并行度? 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# 实时计算 Flink版3179
认真学习的heartAM 2023-11-27 18:23:26 1 我记得可以通过在SQL语句中添加“SET parallelism=n”来实现,其中n为每个节点的并行度。API可以设置每个算子的并行度,SQL只能设置每个节点的并行度。比如 SET node1.parallelism = 4;
665661AM 2023-11-27 18:23:26 2 这是sql和datastream api区别之一,api可以设置每个算子的并行度,sql就不行——该回答整理自钉群“【③群】Apache Flink China社区”
我记得可以通过在SQL语句中添加“SET parallelism=n”来实现,其中n为每个节点的并行度。API可以设置每个算子的并行度,SQL只能设置每个节点的并行度。比如
这是sql和datastream api区别之一,api可以设置每个算子的并行度,sql就不行——该回答整理自钉群“【③群】Apache Flink China社区”