You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2018/03/27 20:28:27 UTC

[kafka] branch 1.0 updated: MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781)

This is an automated email from the ASF dual-hosted git repository.

jgus 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 911259e  MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781)
911259e is described below

commit 911259e677f675ecf00e56189b875e4e6c343f3d
Author: Manikumar Reddy O <ma...@gmail.com>
AuthorDate: Wed Mar 28 01:48:53 2018 +0530

    MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781)
    
    Reviewers: Dong Lin <li...@gmail.com>, Jason Gustafson <ja...@confluent.io>
---
 .../test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala b/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
index 19a3a2f..5bb912b 100644
--- a/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
+++ b/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
@@ -99,7 +99,9 @@ class ReassignPartitionsClusterTest extends ZooKeeperTestHarness with Logging {
     )
 
     assertEquals(100, newLeaderServer.replicaManager.getReplicaOrException(topicPartition).highWatermark.messageOffset)
-    servers.foreach(server => waitUntilTrue(() => server.replicaManager.getReplicaOrException(topicPartition).highWatermark.messageOffset == 100, ""))
+    val newFollowerServer = servers.find(_.config.brokerId == 102).get
+    TestUtils.waitUntilTrue(() => newFollowerServer.replicaManager.getReplicaOrException(topicPartition).highWatermark.messageOffset == 100,
+      "partition follower's highWatermark should be 100")
   }
 
 

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