请问一下Flink,咱们这个平台怎么关闭 动态调整并发度 的功能? 因为我在测试环境,用的和生产环境相同的Jar包, 测试环境不想调整那么放开调整那么多并发度, 设置了全局并发度,好像也没控制住
以下为热心网友提供的参考意见
要关闭Flink的动态调整并发度功能,可以通过设置execution.adaptive.enabled
参数为false
来实现。在Flink的配置文件(通常是flink-conf.yaml
)中添加以下配置:
execution:
adaptive:
enabled: false
这样设置后,Flink将不会根据作业的实际负载情况动态调整并发度。请注意,这可能会导致资源利用率不高或者作业执行时间较长。
本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/19605.html