[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822468908 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -109,54 +116,90

[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822468908 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -109,54 +116,90

[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822468908 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -109,54 +116,90

[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r821468782 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -531,7 +531,9 @@