From commits-return-9279-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Tue Mar 27 22:18:59 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 07F9918064E for ; Tue, 27 Mar 2018 22:18:58 +0200 (CEST) Received: (qmail 73895 invoked by uid 500); 27 Mar 2018 20:18:58 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 73886 invoked by uid 99); 27 Mar 2018 20:18:57 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 27 Mar 2018 20:18:57 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 785A080A33; Tue, 27 Mar 2018 20:18:57 +0000 (UTC) Date: Tue, 27 Mar 2018 20:18:57 +0000 To: "commits@kafka.apache.org" Subject: [kafka] branch trunk updated: MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <152218193699.26435.15112351873419670688@gitbox.apache.org> From: jgus@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: kafka X-Git-Refname: refs/heads/trunk X-Git-Reftype: branch X-Git-Oldrev: 9eb32eaad5fa3863d60b84ef095fa041e83b7b47 X-Git-Newrev: 395c7e0f0985b424ea2bc2bd40c0237eada24dcf X-Git-Rev: 395c7e0f0985b424ea2bc2bd40c0237eada24dcf X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated 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 AuthorDate: Wed Mar 28 01:48:53 2018 +0530 MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (#4781) Reviewers: Dong Lin , Jason Gustafson --- .../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.