Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5518#discussion_r169991026 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1991,43 +2034,87 @@ public int numStateEntries() { return count; } - private static class RocksIteratorWrapper<K> implements Iterator<K> { + /** + * This class is not thread safety. --- End diff -- ð
---