From 842fe7e0e7e2998e3b7909a91a6fd641d58b4ea5 Mon Sep 17 00:00:00 2001
From: ableegoldman <sophie@confluent.io>
Date: Thu, 11 Jul 2019 16:51:29 -0700
Subject: [PATCH] closed

---
 .../streams/state/internals/RocksDBSegmentedBytesStore.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java
index 0ed4e9d78f2d8..cef8a34e9a4b1 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java
@@ -211,6 +211,7 @@ void restoreAllInternal(final Collection<KeyValue<byte[], byte[]>> records) {
                 final KeyValueSegment segment = entry.getKey();
                 final WriteBatch batch = entry.getValue();
                 segment.write(batch);
+                batch.close();
             }
         } catch (final RocksDBException e) {
             throw new ProcessorStateException("Error restoring batch to store " + this.name, e);