[GitHub] [flink] rkhachatryan commented on a change in pull request #13565: [FLINK-17073][checkpointing] Backpressure checkpointing on slow cleanup

rkhachatryan commented on a change in pull request #13565: URL: https://github.com/apache/flink/pull/13565#discussion_r551426315 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java ## @@ -84,7 +85,7 @@ default CompletedCh

[GitHub] [flink] rkhachatryan commented on a change in pull request #13565: [FLINK-17073][checkpointing] Backpressure checkpointing on slow cleanup

rkhachatryan commented on a change in pull request #13565: URL: https://github.com/apache/flink/pull/13565#discussion_r503866063 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java ## @@ -531,6 +527,30 @@ private void dispose(bo

[GitHub] [flink] rkhachatryan commented on a change in pull request #13565: [FLINK-17073][checkpointing] Backpressure checkpointing on slow cleanup

rkhachatryan commented on a change in pull request #13565: URL: https://github.com/apache/flink/pull/13565#discussion_r503730533 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java ## @@ -531,6 +527,30 @@ private void dispose(bo