[hotfix] [rocksdb] Only log snapshot restore message when state is ac…

…tually restored
deepfield · Jan 8, 2019 · ef08a86 · ef08a86
1 parent 7a1147b
commit ef08a86
Showing 1 changed file with 4 additions and 4 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
@@ -517,10 +517,6 @@ public void restore(Collection<KeyedStateHandle> restoreState) throws Exception
 
  LOG.info("Initializing RocksDB keyed state backend.");
 
- if (LOG.isDebugEnabled()) {
- LOG.debug("Restoring snapshot from state handles: {}, will use {} thread(s) to download files from DFS.", restoreState, restoringThreadNum);
- }
-
  // clear all meta data
  kvStateInformation.clear();
 
@@ -529,6 +525,10 @@ public void restore(Collection<KeyedStateHandle> restoreState) throws Exception
  if (restoreState == null || restoreState.isEmpty()) {
  createDB();
  } else {
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Restoring snapshot from state handles: {}, will use {} thread(s) to download files from DFS.", restoreState, restoringThreadNum);
+ }
+
  KeyedStateHandle firstStateHandle = restoreState.iterator().next();
  if (firstStateHandle instanceof IncrementalKeyedStateHandle
  || firstStateHandle instanceof IncrementalLocalKeyedStateHandle) {