[GitHub] [flink] dmvk commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
dmvk commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r805959938 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java ## @@ -205,6 +218,14 @@ AssignmentResult t

[GitHub] [flink] dmvk commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
dmvk commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r806844044 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java ## @@ -155,6 +179,60 @@ public void t

[GitHub] [flink] dmvk commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
dmvk commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r806700558 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java ## @@ -155,6 +179,60 @@ public void t

[GitHub] [flink] dmvk commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-14 Thread GitBox
dmvk commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r805984592 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java ## @@ -135,10 +139,16 @@ public void

[GitHub] [flink] dmvk commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-14 Thread GitBox
dmvk commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r805966165 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java ## @@ -149,9 +159,27 @@ public void t

[GitHub] [flink] dmvk commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-14 Thread GitBox
dmvk commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r805959938 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java ## @@ -205,6 +218,14 @@ AssignmentResult t