[hotfix][rocksdb] fix exception message upon failure to create directory

deepfield · Dec 3, 2019 · 95ad441 · 95ad441
1 parent faf394d
commit 95ad441
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...a/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java b/...a/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java
@@ -190,7 +190,7 @@ private SnapshotDirectory prepareLocalSnapshotDirectory(long checkpointId) throw
 
  if (!directory.exists() && !directory.mkdirs()) {
  throw new IOException("Local state base directory for checkpoint " + checkpointId +
- " already exists: " + directory);
+ " does not exist and could not be created: " + directory);
  }
 
  // introduces an extra directory because RocksDB wants a non-existing directory for native checkpoints.