[GitHub] [flink] AHeise commented on a change in pull request #15613: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

AHeise commented on a change in pull request #15613: URL: https://github.com/apache/flink/pull/15613#discussion_r614042775 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ## @@ -876,6 +887,8 @@ public void run(SourceContext

[GitHub] [flink] AHeise commented on a change in pull request #15613: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

AHeise commented on a change in pull request #15613: URL: https://github.com/apache/flink/pull/15613#discussion_r613836901 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ## @@ -876,6 +887,8 @@ public void run(SourceContext

[GitHub] [flink] AHeise commented on a change in pull request #15613: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

AHeise commented on a change in pull request #15613: URL: https://github.com/apache/flink/pull/15613#discussion_r613834085 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ## @@ -852,6 +862,7 @@ public void invoke(IN value)