From 43fe13350f7a4c74cd101cbb69a01d062f5c9329 Mon Sep 17 00:00:00 2001 From: Kamal Chandraprakash Date: Fri, 1 Sep 2023 00:09:26 +0530 Subject: [PATCH] KAFKA-15404: Disable the flaky integration tests. (#14296) Disabled the below tests to fix the thread leak: 1. kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize() and 2. org.apache.kafka.tiered.storage.integration.OffloadAndConsumeFromLeaderTest Reviewers: Luke Chen , Divij Vaidya , Justine Olshan --- .../kafka/server/DynamicBrokerReconfigurationTest.scala | 1 + .../apache/kafka/tiered/storage/TieredStorageTestHarness.java | 2 ++ 2 files changed, 3 insertions(+) diff --git a/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala b/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala index c92287184a8a8..fcbc7f6fe9ef3 100644 --- a/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala +++ b/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala @@ -798,6 +798,7 @@ class DynamicBrokerReconfigurationTest extends QuorumTestHarness with SaslSetup consumer.commitSync() } + @Disabled @Test def testThreadPoolResize(): Unit = { val requestHandlerPrefix = "data-plane-kafka-request-handler-" diff --git a/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestHarness.java b/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestHarness.java index bed5452bdf50a..c22fc29aeb825 100644 --- a/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestHarness.java +++ b/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestHarness.java @@ -32,6 +32,7 @@ import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Tag; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.TestInfo; @@ -154,6 +155,7 @@ public void setUp(TestInfo testInfo) { context = new TieredStorageTestContext(this); } + @Disabled @Test public void executeTieredStorageTest() { TieredStorageTestBuilder builder = new TieredStorageTestBuilder();