kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 1.0 updated: HOTFIX: fix StreamPartitionAssignorTest
Date Wed, 31 Jan 2018 03:16:25 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.0 by this push:
     new 27ffa35  HOTFIX: fix StreamPartitionAssignorTest
27ffa35 is described below

commit 27ffa350b010e147739076bf7cfc23626b3970c4
Author: Matthias J. Sax <matthias@confluent.io>
AuthorDate: Tue Jan 30 18:36:57 2018 -0800

    HOTFIX: fix StreamPartitionAssignorTest
---
 .../streams/processor/internals/StreamPartitionAssignorTest.java   | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java
index c5d5d6d..918b6aa 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java
@@ -151,7 +151,6 @@ public class StreamPartitionAssignorTest {
         EasyMock.replay(threadDataProvider);
     }
 
-
     @Test
     public void shouldInterleaveTasksByGroupId() {
         final TaskId taskIdA0 = new TaskId(0, 0);
@@ -310,10 +309,10 @@ public class StreamPartitionAssignorTest {
 
         final UUID uuid1 = UUID.randomUUID();
 
-        mockTaskManager(new HashSet<TaskId>(), new HashSet<TaskId>(), uuid1,
builder);
-        configurePartitionAssignor(Collections.<String, Object>emptyMap());
+        mockThreadDataProvider(new HashSet<TaskId>(), new HashSet<TaskId>(),
uuid1, defaultPartitionGrouper, builder);
+        configurePartitionAssignor(0, null);
 
-        partitionAssignor.setInternalTopicManager(new MockInternalTopicManager(streamsConfig,
mockClientSupplier.restoreConsumer));
+        partitionAssignor.setInternalTopicManager(new MockInternalTopicManager(config, mockClientSupplier.restoreConsumer));
 
         final Map<String, PartitionAssignor.Subscription> subscriptions = new HashMap<>();
         subscriptions.put("consumer10",

-- 
To stop receiving notification emails like this one, please contact
mjsax@apache.org.

Mime
View raw message