From dfcbb7106c81d8e568ef76390d4e9724872d3a25 Mon Sep 17 00:00:00 2001 From: Guozhang Wang Date: Mon, 5 Oct 2015 11:02:26 -0700 Subject: [PATCH 1/2] fix ProcessorStateManagerTest --- .../processor/internals/ProcessorStateManagerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java index 3049d51f3a74f..c79be52ce1a22 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java @@ -283,7 +283,7 @@ public void testRegisterPersistentStore() throws IOException { )); restoreConsumer.updateEndOffsets(Collections.singletonMap(new TopicPartition("persistentStore", 2), 13L)); - MockStateStore persistentStore = new MockStateStore("persistentStore", false); // non persistent store + MockStateStore persistentStore = new MockStateStore("persistentStore", true); // persistent store ProcessorStateManager stateMgr = new ProcessorStateManager(2, baseDir, restoreConsumer); try { @@ -331,7 +331,7 @@ public void testRegisterNonPersistentStore() throws IOException { )); restoreConsumer.updateEndOffsets(Collections.singletonMap(new TopicPartition("persistentStore", 2), 13L)); - MockStateStore nonPersistentStore = new MockStateStore("nonPersistentStore", true); // persistent store + MockStateStore nonPersistentStore = new MockStateStore("nonPersistentStore", true); // non persistent store ProcessorStateManager stateMgr = new ProcessorStateManager(2, baseDir, restoreConsumer); try { From 3cc6b520b59960b66c81ea6ac75ad641f091a16e Mon Sep 17 00:00:00 2001 From: Guozhang Wang Date: Mon, 5 Oct 2015 11:11:05 -0700 Subject: [PATCH 2/2] Ismael's comments --- .../streams/processor/internals/ProcessorStateManagerTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java index c79be52ce1a22..eb33dc3596044 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java @@ -331,7 +331,7 @@ public void testRegisterNonPersistentStore() throws IOException { )); restoreConsumer.updateEndOffsets(Collections.singletonMap(new TopicPartition("persistentStore", 2), 13L)); - MockStateStore nonPersistentStore = new MockStateStore("nonPersistentStore", true); // non persistent store + MockStateStore nonPersistentStore = new MockStateStore("nonPersistentStore", false); // non persistent store ProcessorStateManager stateMgr = new ProcessorStateManager(2, baseDir, restoreConsumer); try {