kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 2.1 updated: KAFKA-8637: WriteBatch objects leak off-heap memory
Date Fri, 12 Jul 2019 17:21:03 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.1 by this push:
     new b5ea03e  KAFKA-8637: WriteBatch objects leak off-heap memory
b5ea03e is described below

commit b5ea03e0dee01d610c2d92b1436fd80d9d3dab7b
Author: A. Sophie Blee-Goldman <sophie@confluent.io>
AuthorDate: Fri Jul 12 10:19:50 2019 -0700

    KAFKA-8637: WriteBatch objects leak off-heap memory
    
    Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>
---
 .../apache/kafka/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 c4fce72..0669446 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
@@ -212,6 +212,7 @@ class RocksDBSegmentedBytesStore implements SegmentedBytesStore {
                 final Segment 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);


Mime
View raw message