flink sql 现在是不是能给算子单独调整并行度了啊?
以下为热心网友提供的参考意见
是的,Flink SQL可以给算子单独调整并行度。具体来说,有两种主要方式可以进行设置:
-
在Flink Web UI中进行调整:你可以找到对应的Flink Job,点击进入Job的详情页,然后在任务算子的后面找到“并行度”一栏,点击“Edit”按钮,即可修改并行度参数。
-
在代码中进行设置:可以在算子后跟着调用setParallelism()方法,来设置当前算子的并行度。这种方式设置的并行度,只针对当前算子有效。
以下为热心网友提供的参考意见
no ,此回答整理自钉群“【③群】Apache Flink China社区”
以下为热心网友提供的参考意见
Flink SQL并不直接支持为每个算子单独设置并行度。在Flink SQL中,通常是在创建表或执行作业时指定一个全局的并行度。
本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/11491.html