[GitHub] [flink] akalash commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-05-03 Thread GitBox
akalash commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r625177400 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculatorTest.java ## @@ -149,18 +150,80 @@ public

[GitHub] [flink] akalash commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-04-27 Thread GitBox
akalash commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r621160215 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java ## @@ -111,7 +112,10 @@ public void

[GitHub] [flink] akalash commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-04-26 Thread GitBox
akalash commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r620571204 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java ## @@ -111,7 +112,10 @@ public void

[GitHub] [flink] akalash commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-04-26 Thread GitBox
akalash commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r620414538 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java ## @@ -111,7 +112,10 @@ public void

[GitHub] [flink] akalash commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-04-26 Thread GitBox
akalash commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r620235679 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculatorTest.java ## @@ -149,23 +151,114 @@ public