[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r771222456 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1261,6 +1269,10 @@ private void

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r771214095 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java ## @@ -89,6 +94,11 @@ boolean forceCheckpoint()

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r771189151 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java ## @@ -89,6 +94,11 @@ boolean forceCheckpoint()

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r771188328 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java ## @@ -116,6 +116,11 @@ public

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r770537322 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointOptions.java ## @@ -73,30 +73,29 @@ public static

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r770529350 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java ## @@ -116,6 +116,11 @@ public

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r770504698 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r770418273 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r770418273 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r770273532 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r769486247 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1271,6 +1273,18 @@ private boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r769486247 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1271,6 +1273,18 @@ private boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r769477323 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1650,6 +1657,10 @@ public boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r769356414 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1664,10 +1675,13 @@ public boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r769355897 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1650,6 +1657,10 @@ public boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768928786 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java ## @@ -172,4 +174,19 @@ OperatorStateBackend

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768941388 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1271,6 +1273,18 @@ private boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768928786 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java ## @@ -172,4 +174,19 @@ OperatorStateBackend

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768852184 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointOptions.java ## @@ -179,6 +254,16 @@ public

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768698948 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -875,6 +890,21 @@ public JobExecutionResult

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768644599 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1271,6 +1273,18 @@ private boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768644599 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1271,6 +1273,18 @@ private boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768644599 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1271,6 +1273,18 @@ private boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768539890 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1664,10 +1675,13 @@ public boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768546894 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768543573 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -875,6 +890,21 @@ public JobExecutionResult

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768539890 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1664,10 +1675,13 @@ public boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768535275 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1271,6 +1273,18 @@ private boolean

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768532544 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java ## @@ -172,4 +174,19 @@ OperatorStateBackend

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768485412 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java ## @@ -135,7 +135,9 @@ public void

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768482638 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java ## @@ -172,4 +174,19 @@ OperatorStateBackend

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r768482638 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java ## @@ -172,4 +174,19 @@ OperatorStateBackend

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r767303555 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java ## @@ -172,4 +174,19 @@ OperatorStateBackend