kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781)
Date Tue, 27 Mar 2018 20:18:57 GMT
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 <manikumar.reddy@gmail.com>
AuthorDate: Wed Mar 28 01:48:53 2018 +0530

    MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781)
    
    Reviewers: Dong Lin <lindong28@gmail.com>, Jason Gustafson <jason@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.

Mime
View raw message