[GitHub] [flink] akalash commented on a change in pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

akalash commented on a change in pull request #16102: URL: https://github.com/apache/flink/pull/16102#discussion_r649190119 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/IgnoreInFlightDataITCase.java ## @@ -98,75 +123,122 @@ public void

[GitHub] [flink] akalash commented on a change in pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

akalash commented on a change in pull request #16102: URL: https://github.com/apache/flink/pull/16102#discussion_r648958362 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/IgnoreInFlightDataITCase.java ## @@ -107,17 +111,27 @@ public void

[GitHub] [flink] akalash commented on a change in pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

akalash commented on a change in pull request #16102: URL: https://github.com/apache/flink/pull/16102#discussion_r648501659 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/IgnoreInFlightDataITCase.java ## @@ -107,17 +111,27 @@ public void

[GitHub] [flink] akalash commented on a change in pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

akalash commented on a change in pull request #16102: URL: https://github.com/apache/flink/pull/16102#discussion_r648366475 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/IgnoreInFlightDataITCase.java ## @@ -179,11 +205,30 @@ public void