Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4764#discussion_r142579521
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -356,28 +354,26 @@ public int getKeyGroupPrefixBytes() {
final long checkpointTimestamp,
final CheckpointStreamFactory checkpointStreamFactory) throws
Exception {
+ if (db == null) {
+ throw new IOException("RocksDB closed.");
--- End diff --
This exception message looks a bit odd to me. Can you please enrich the
message? E.g. "RocksDB has been closed expected. <suggestion for a solution>"?
---
