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

rkhachatryan commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r769936610 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrate

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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