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

[jg...@apache.org]

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

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


The following commit(s) were added to refs/heads/trunk by this push:
     new 395c7e0  MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781)
395c7e0 is described below

commit 395c7e0f0985b424ea2bc2bd40c0237eada24dcf
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 0c41519..b42d7f7 100644
--- a/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
+++ b/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
@@ -98,7 +98,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.