kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: HOTFIX: fix build compilation error
Date Thu, 28 Sep 2017 11:53:36 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 071f9fe1a -> 9d0a89aea


HOTFIX: fix build compilation error

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Ismael Juma <ismael@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 <damian.guy@gmail.com>
Authored: Thu Sep 28 12:53:30 2017 +0100
Committer: Damian Guy <damian.guy@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));


Mime
View raw message