diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java index 05db0eadd04..74f091936d2 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java @@ -81,6 +81,7 @@ public class RocksDBTimestampedStore extends RocksDBStore implements Timestamped } else { log.info("Opening store {} in regular mode", name); dbAccessor = new SingleColumnFamilyAccessor(columnFamilies.get(1)); + noTimestampColumnFamily.close(); } noTimestampsIter.close(); } catch (final RocksDBException e) {