kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: Persistent store in ProcessorStateManagerTest
Date Mon, 05 Oct 2015 20:54:55 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk b88ba9a6b -> f236bc20f


HOTFIX: Persistent store in ProcessorStateManagerTest

ymatsuda junrao Could you take a quick look? The current unit test is failing on this.

Author: Guozhang Wang <wangguoz@gmail.com>

Reviewers: Ismael Juma, Jun Rao

Closes #276 from guozhangwang/HF-ProcessorStateManager


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f236bc20
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f236bc20
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f236bc20

Branch: refs/heads/trunk
Commit: f236bc20ff5995aa367089afcd0a6738aaaae754
Parents: b88ba9a
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Mon Oct 5 13:59:04 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Mon Oct 5 13:59:04 2015 -0700

----------------------------------------------------------------------
 .../streams/processor/internals/ProcessorStateManagerTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f236bc20/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
----------------------------------------------------------------------
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 3049d51..eb33dc3 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 class ProcessorStateManagerTest {
             ));
             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 class ProcessorStateManagerTest {
             ));
             restoreConsumer.updateEndOffsets(Collections.singletonMap(new TopicPartition("persistentStore",
2), 13L));
 
-            MockStateStore nonPersistentStore = new MockStateStore("nonPersistentStore",
true); // persistent store
+            MockStateStore nonPersistentStore = new MockStateStore("nonPersistentStore",
false); // non persistent store
 
             ProcessorStateManager stateMgr = new ProcessorStateManager(2, baseDir, restoreConsumer);
             try {


Mime
View raw message