You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2021/02/24 16:20:56 UTC
[flink] 01/09: [hotfix] Remove unnecessary if in
RocksIncrementalSnapshotStrategy
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2f16bff7547c81539f9f34eff1ae380e20efea13
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Tue Feb 2 13:28:54 2021 +0100
[hotfix] Remove unnecessary if in RocksIncrementalSnapshotStrategy
---
.../state/snapshot/RocksIncrementalSnapshotStrategy.java | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java
index 0921924..682a3f7 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java
@@ -177,18 +177,12 @@ public class RocksIncrementalSnapshotStrategy<K>
return registry -> SnapshotResult.empty();
}
- List<StateMetaInfoSnapshot> stateMetaInfoSnapshots =
- snapshotResources.stateMetaInfoSnapshots;
- if (stateMetaInfoSnapshots.isEmpty()) {
- return snapshotCloseableRegistry -> SnapshotResult.empty();
- }
-
return new RocksDBIncrementalSnapshotOperation(
checkpointId,
checkpointStreamFactory,
snapshotResources.snapshotDirectory,
snapshotResources.baseSstFiles,
- stateMetaInfoSnapshots);
+ snapshotResources.stateMetaInfoSnapshots);
}
@Override