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
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
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
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
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
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