You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2017/09/28 11:53:36 UTC
kafka git commit: HOTFIX: fix build compilation error
Repository: kafka
Updated Branches:
refs/heads/trunk 071f9fe1a -> 9d0a89aea
HOTFIX: fix build compilation error
Author: Damian Guy <da...@gmail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
Closes #3981 from dguy/fix-build
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9d0a89ae
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9d0a89ae
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9d0a89ae
Branch: refs/heads/trunk
Commit: 9d0a89aea5252e5b7ff8deff707547e6a6dbbc4f
Parents: 071f9fe
Author: Damian Guy <da...@gmail.com>
Authored: Thu Sep 28 12:53:30 2017 +0100
Committer: Damian Guy <da...@gmail.com>
Committed: Thu Sep 28 12:53:30 2017 +0100
----------------------------------------------------------------------
.../streams/processor/internals/GlobalStateManagerImplTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/9d0a89ae/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java
index 0519fb0..e9d61f5 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java
@@ -214,7 +214,7 @@ public class GlobalStateManagerImplTest {
stateManager.initialize(context);
final TheStateRestoreCallback stateRestoreCallback = new TheStateRestoreCallback();
- stateManager.register(store1, false, stateRestoreCallback);
+ stateManager.register(store1, stateRestoreCallback);
assertThat(stateRestoreListener.restoreStartOffset, equalTo(1L));
assertThat(stateRestoreListener.restoreEndOffset, equalTo(5L));