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;

Reply via email to