You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/10/05 22:54:55 UTC
kafka git commit: HOTFIX: Persistent store in
ProcessorStateManagerTest
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 <wa...@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 <wa...@gmail.com>
Authored: Mon Oct 5 13:59:04 2015 -0700
Committer: Guozhang Wang <wa...@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 {