This is an automated email from the ASF dual-hosted git repository. guozhang 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 11b25a1 MINOR: Fix DistributedHerderTest after adding reason to maybeLeaveGroup (#6982) 11b25a1 is described below commit 11b25a13ee72e1c91facd0f94b888215f67d5a69 Author: Konstantine Karantasis <konstant...@confluent.io> AuthorDate: Fri Jun 21 12:42:34 2019 -0700 MINOR: Fix DistributedHerderTest after adding reason to maybeLeaveGroup (#6982) Mocking of WorkerCoordinator was not precise after adding an argument (reason) to AbstractCoordinator#maybeLeaveGroup in KAFKA-8569: Unit test case for DistributedHerderTest is now precise with respect to the expected argument and succeeds Reviewers: Boyang Chen <boy...@confluent.io>, Guozhang Wang <wangg...@gmail.com> --- .../apache/kafka/connect/runtime/distributed/DistributedHerderTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java b/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java index f6cbfd6..bc40a61 100644 --- a/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java +++ b/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java @@ -1442,7 +1442,7 @@ public class DistributedHerderTest { // Reading to end of log times out configBackingStore.refresh(EasyMock.anyLong(), EasyMock.anyObject(TimeUnit.class)); EasyMock.expectLastCall().andThrow(new TimeoutException()); - member.maybeLeaveGroup("test join leader catch up fails"); + member.maybeLeaveGroup(EasyMock.eq("taking too long to read the log")); EasyMock.expectLastCall(); PowerMock.expectPrivate(herder, "backoff", DistributedConfig.WORKER_UNSYNC_BACKOFF_MS_DEFAULT); member.requestRejoin();