Repository: kafka Updated Branches: refs/heads/0.10.2 c1c680e18 -> 363348932
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 (cherry picked from commit 675881b0f1138c6c09ff4700b17f008ea9053aa4) Signed-off-by: Guozhang Wang <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/36334893 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/36334893 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/36334893 Branch: refs/heads/0.10.2 Commit: 3633489324ccc53fd0a9e30ac3c1bb4c7f13297b Parents: c1c680e 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:52 2017 -0800 ---------------------------------------------------------------------- .../kafka/streams/state/internals/CachingSessionStoreTest.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/36334893/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);
