[hotfix] Do not track completed checkpoint ids without incremental checkpointing
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7b5c53f5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7b5c53f5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7b5c53f5 Branch: refs/heads/master Commit: 7b5c53f55417849d430426f0babc5794bad5430a Parents: 2b55ffb Author: Stefan Richter <[email protected]> Authored: Sun Feb 25 14:34:24 2018 +0100 Committer: Stefan Richter <[email protected]> Committed: Sun Feb 25 15:10:28 2018 +0100 ---------------------------------------------------------------------- .../contrib/streaming/state/RocksDBKeyedStateBackend.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/7b5c53f5/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---------------------------------------------------------------------- diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java index 76cd5e4..4fc0283 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java @@ -1082,7 +1082,13 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { @Override public void notifyCheckpointComplete(long completedCheckpointId) { + + if (!enableIncrementalCheckpointing) { + return; + } + synchronized (materializedSstFiles) { + if (completedCheckpointId < lastCompletedCheckpointId) { return; }
