[kafka] branch 2.2 updated: MINOR: drop dbAccessor reference on close (#6254)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/2.2 by this push:
     new faaa84e  MINOR: drop dbAccessor reference on close (#6254)
faaa84e is described below

commit faaa84ec41ad14a25b4006285ce81c409c5e0d11
Author: John Roesler <vv...@users.noreply.github.com>
AuthorDate: Thu Feb 14 11:59:01 2019 -0600

    MINOR: drop dbAccessor reference on close (#6254)
    
    Reviewers: Bill Bejeck <bi...@confluent.io>, Matthias J. Sax <ma...@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;