kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2815: Fix KafkaStreamingPartitionAssignorTest.testSubscription
Date Thu, 12 Nov 2015 17:53:41 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk d9a455243 -> 370ce2b4b


KAFKA-2815: Fix KafkaStreamingPartitionAssignorTest.testSubscription

Fails when order of elements is incorrect

Author: Grant Henke <granthenke@gmail.com>

Reviewers: Yasuhiro Matsuda

Closes #510 from granthenke/streams-test


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/370ce2b4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/370ce2b4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/370ce2b4

Branch: refs/heads/trunk
Commit: 370ce2b4b73b60ca52a4fbce246f3fd87b8dbf85
Parents: d9a4552
Author: Grant Henke <granthenke@gmail.com>
Authored: Thu Nov 12 09:59:47 2015 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Nov 12 09:59:47 2015 -0800

----------------------------------------------------------------------
 .../processor/internals/KafkaStreamingPartitionAssignorTest.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/370ce2b4/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java
index 86434fb..c0df2e7 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java
@@ -171,6 +171,7 @@ public class KafkaStreamingPartitionAssignorTest {
 
         PartitionAssignor.Subscription subscription = partitionAssignor.subscription(Utils.mkSet("topic1",
"topic2"));
 
+        Collections.sort(subscription.topics());
         assertEquals(Utils.mkList("topic1", "topic2"), subscription.topics());
 
         Set<TaskId> standbyTasks = new HashSet<>(cachedTasks);


Mime
View raw message