subject:"\[GitHub\] \[flink\] reswqa commented on a diff in pull request #22608\: \[FLINK\-31893\]\[runtime\] Introduce AdaptiveBatchScheduler failure enrichment\/labeling"

[GitHub] [flink] reswqa commented on a diff in pull request #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

2023-05-20 Thread via GitHub

reswqa commented on code in PR #22608: URL: https://github.com/apache/flink/pull/22608#discussion_r1199639985 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java: ## @@ -91,6 +95,31 @@ void setUp() { taskRestar

[GitHub] [flink] reswqa commented on a diff in pull request #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

2023-05-20 Thread via GitHub

reswqa commented on code in PR #22608: URL: https://github.com/apache/flink/pull/22608#discussion_r1199639985 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java: ## @@ -91,6 +95,31 @@ void setUp() { taskRestar