You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2018/01/31 03:16:25 UTC
[kafka] branch 1.0 updated: HOTFIX: fix StreamPartitionAssignorTest
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 <ma...@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.