[hotfix] Do not track completed checkpoint ids without incremental ch…

…eckpointing
InfinitiesLoop · Feb 25, 2018 · 7b5c53f · 7b5c53f
1 parent 2b55ffb
commit 7b5c53f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/...ksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
@@ -1082,7 +1082,13 @@ public void restore(Collection<KeyedStateHandle> restoreState) throws Exception
 
  @Override
  public void notifyCheckpointComplete(long completedCheckpointId) {
+
+ if (!enableIncrementalCheckpointing) {
+ return;
+ }
+
  synchronized (materializedSstFiles) {
+
  if (completedCheckpointId < lastCompletedCheckpointId) {
  return;
  }