This is an automated email from the ASF dual-hosted git repository. mjsax pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new b12b7f0 MINOR: drop dbAccessor reference on close (#6254) b12b7f0 is described below commit b12b7f0435f6163af25bce8797b054762d65de5a Author: John Roesler <vvcep...@users.noreply.github.com> AuthorDate: Thu Feb 14 11:59:01 2019 -0600 MINOR: drop dbAccessor reference on close (#6254) Reviewers: Bill Bejeck <b...@confluent.io>, Matthias J. Sax <matth...@confluent.io> --- .../main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java | 1 + 1 file changed, 1 insertion(+) diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java index 0528fca..2ca3ad3 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java @@ -377,6 +377,7 @@ public class RocksDBStore implements KeyValueStore<Bytes, byte[]> { fOptions.close(); db.close(); + dbAccessor = null; userSpecifiedOptions = null; wOptions = null; fOptions = null;