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 <dwysakow...@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