From b079bc80ef9aa7b19caea20bd5f219db0539ae93 Mon Sep 17 00:00:00 2001 From: TaiJu Wu Date: Tue, 14 Jan 2025 18:45:34 +0000 Subject: [PATCH 1/2] close resource --- .../clients/consumer/internals/AbstractCoordinatorTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java index 969de83c328ff..eda9f01c4a3a4 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java @@ -116,6 +116,7 @@ public class AbstractCoordinatorTest { public void closeCoordinator() { Utils.closeQuietly(coordinator, "close coordinator"); Utils.closeQuietly(consumerClient, "close consumer client"); + Utils.closeQuietly(mockClient, "close mock client"); } private void setupCoordinator() { @@ -1506,7 +1507,6 @@ public void testWakeupAfterSyncGroupReceived() throws Exception { awaitFirstHeartbeat(heartbeatReceived); } - @Tag("flaky") // KAFKA-15474 and KAFKA-18310 @Test public void testWakeupAfterSyncGroupReceivedExternalCompletion() throws Exception { setupCoordinator(); From 505779bc8dd298ddffa1ab8e576d5722a80e39f8 Mon Sep 17 00:00:00 2001 From: TaiJu Wu Date: Wed, 15 Jan 2025 15:45:41 +0000 Subject: [PATCH 2/2] revert flaky tag --- .../clients/consumer/internals/AbstractCoordinatorTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java index eda9f01c4a3a4..84113d016b671 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java @@ -1507,6 +1507,7 @@ public void testWakeupAfterSyncGroupReceived() throws Exception { awaitFirstHeartbeat(heartbeatReceived); } + @Tag("flaky") // KAFKA-15474 and KAFKA-18310 @Test public void testWakeupAfterSyncGroupReceivedExternalCompletion() throws Exception { setupCoordinator();