Repository: kafka Updated Branches: refs/heads/trunk 5c2ca30f2 -> 1c93bb16a
trivial change to fix unit test failure introduced in kafka-2234 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1c93bb16 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1c93bb16 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1c93bb16 Branch: refs/heads/trunk Commit: 1c93bb16a91788d3489d4d784c13f1f0fddb6fb7 Parents: 5c2ca30 Author: Jun Rao <jun...@gmail.com> Authored: Thu Jun 18 17:00:34 2015 -0700 Committer: Jun Rao <jun...@gmail.com> Committed: Thu Jun 18 17:00:34 2015 -0700 ---------------------------------------------------------------------- core/src/test/scala/unit/kafka/admin/AdminTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/1c93bb16/core/src/test/scala/unit/kafka/admin/AdminTest.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/unit/kafka/admin/AdminTest.scala b/core/src/test/scala/unit/kafka/admin/AdminTest.scala index efb2f8e..252ac81 100755 --- a/core/src/test/scala/unit/kafka/admin/AdminTest.scala +++ b/core/src/test/scala/unit/kafka/admin/AdminTest.scala @@ -242,7 +242,7 @@ class AdminTest extends JUnit3Suite with ZooKeeperTestHarness with Logging { val partitionToBeReassigned = 0 val topicAndPartition = TopicAndPartition(topic, partitionToBeReassigned) val reassignPartitionsCommand = new ReassignPartitionsCommand(zkClient, Map(topicAndPartition -> newReplicas)) - assertTrue("Partition reassignment failed for test, 0", reassignPartitionsCommand.reassignPartitions()) + assertFalse("Partition reassignment failed for test, 0", reassignPartitionsCommand.reassignPartitions()) val reassignedPartitions = ZkUtils.getPartitionsBeingReassigned(zkClient) assertFalse("Partition should not be reassigned", reassignedPartitions.contains(topicAndPartition)) servers.foreach(_.shutdown())
