Repository: kafka Updated Branches: refs/heads/trunk 2a5db4d6c -> 675881b0f
MINOR: close state store in CachingSessionStoreTest close the sessions store in `After` to release rocksdb resources. Author: Damian Guy <[email protected]> Reviewers: Guozhang Wang <[email protected]> Closes #2430 from dguy/minor-close-sesion-store Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/675881b0 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/675881b0 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/675881b0 Branch: refs/heads/trunk Commit: 675881b0f1138c6c09ff4700b17f008ea9053aa4 Parents: 2a5db4d Author: Damian Guy <[email protected]> Authored: Tue Jan 24 15:40:45 2017 -0800 Committer: Guozhang Wang <[email protected]> Committed: Tue Jan 24 15:40:45 2017 -0800 ---------------------------------------------------------------------- .../kafka/streams/state/internals/CachingSessionStoreTest.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/675881b0/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java ---------------------------------------------------------------------- diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java index 65a249e..0475031 100644 --- a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java @@ -32,6 +32,7 @@ import org.apache.kafka.streams.state.KeyValueIterator; import org.apache.kafka.streams.state.StateSerdes; import org.apache.kafka.test.MockProcessorContext; import org.apache.kafka.test.TestUtils; +import org.junit.After; import org.junit.Before; import org.junit.Test; @@ -69,6 +70,11 @@ public class CachingSessionStoreTest { cachingStore.init(context, cachingStore); } + @After + public void close() { + cachingStore.close(); + } + @Test public void shouldPutFetchFromCache() throws Exception { cachingStore.put(new Windowed<>("a", new SessionWindow(0, 0)), 1L);
