Browse Source

Should close filter in RocksDBStoreTest as well (#6676)

Forgot to also close the filter in RocksDBStoreTest in time.

Reviewers: Bill Bejeck <bbejeck@gmail.com>
pull/6679/head
A. Sophie Blee-Goldman 6 years ago committed by Bill Bejeck
parent
commit
c85152f5b9
  1. 5
      streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java

5
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java

@ -67,6 +67,7 @@ public class RocksDBStoreTest { @@ -67,6 +67,7 @@ public class RocksDBStoreTest {
InternalMockProcessorContext context;
RocksDBStore rocksDBStore;
private static BloomFilter filter;
@Before
public void setUp() {
@ -78,6 +79,7 @@ public class RocksDBStoreTest { @@ -78,6 +79,7 @@ public class RocksDBStoreTest {
Serdes.String(),
Serdes.String(),
new StreamsConfig(props));
filter = new BloomFilter();
}
RocksDBStore getRocksDBStore() {
@ -86,6 +88,7 @@ public class RocksDBStoreTest { @@ -86,6 +88,7 @@ public class RocksDBStoreTest {
@After
public void tearDown() {
filter.close();
rocksDBStore.close();
}
@ -495,7 +498,7 @@ public class RocksDBStoreTest { @@ -495,7 +498,7 @@ public class RocksDBStoreTest {
tableConfig.setBlockCacheSize(50 * 1024 * 1024L);
tableConfig.setBlockSize(4096L);
if (enableBloomFilters) {
tableConfig.setFilter(new BloomFilter());
tableConfig.setFilter(filter);
options.optimizeFiltersForHits();
bloomFiltersSet = true;
} else {

Loading…
Cancel
Save