[FLINK-8559][RocksDB] Release resources if snapshot operation fails

This closes apache#5412.
spotify · Feb 6, 2018 · dbb81ac · dbb81ac
1 parent 5e41eaa
commit dbb81ac
Showing 1 changed file with 7 additions and 1 deletion.
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
@@ -377,7 +377,13 @@ private RunnableFuture<KeyedStateHandle> snapshotIncrementally(
  checkpointId,
  checkpointTimestamp);
 
- snapshotOperation.takeSnapshot();
+ try {
+ snapshotOperation.takeSnapshot();
+ } catch (Exception e) {
+ snapshotOperation.stop();
+ snapshotOperation.releaseResources(true);
+ throw e;
+ }
 
  return new FutureTask<KeyedStateHandle>(
  new Callable<KeyedStateHandle>() {