flinksql中,如何给每个节点设置单独的并行度?[阿里云实时计算 Flink版]

flinksql中,如何给每个节点设置单独的并行度?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 我记得可以通过在SQL语句中添加“SET parallelism=n”来实现,其中n为每个节点的并行度。API可以设置每个算子的并行度,SQL只能设置每个节点的并行度。比如

    SET node1.parallelism = 4;
  2. 这是sql和datastream api区别之一,api可以设置每个算子的并行度,sql就不行——该回答整理自钉群“【③群】Apache Flink China社区”