[GitHub] [flink] zhuzhurk commented on a diff in pull request #22798: [FLINK-32288][runtime] Improve the scheduling performance of AdaptiveBatchScheduler

2023-06-18 Thread via GitHub
zhuzhurk commented on code in PR #22798: URL: https://github.com/apache/flink/pull/22798#discussion_r122596 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/DefaultInputConsumableDecider.java: ## @@ -65,6 +65,18 @@ public boolean isInputConsumable(

[GitHub] [flink] zhuzhurk commented on a diff in pull request #22798: [FLINK-32288][runtime] Improve the scheduling performance of AdaptiveBatchScheduler

2023-06-18 Thread via GitHub
zhuzhurk commented on code in PR #22798: URL: https://github.com/apache/flink/pull/22798#discussion_r122596 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/DefaultInputConsumableDecider.java: ## @@ -65,6 +65,18 @@ public boolean isInputConsumable(