From d2c248f49c75507f0388226fd2721c627bfdd4ec Mon Sep 17 00:00:00 2001 From: Uddeshya Singh Date: Mon, 8 Sep 2025 17:02:12 +0530 Subject: [PATCH 1/3] Reduce metadata refresh period for broker --- .../druid/testing/embedded/indexing/IngestionSmokeTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java index 668079065c4f..cb23bf565cb3 100644 --- a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java +++ b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java @@ -88,7 +88,7 @@ public class IngestionSmokeTest extends EmbeddedClusterTestBase * Broker with a short metadata refresh period. */ protected EmbeddedBroker broker = new EmbeddedBroker() - .addProperty("druid.sql.planner.metadataRefreshPeriod", "PT1s"); + .addProperty("druid.sql.planner.metadataRefreshPeriod", "PT0.1s"); /** * Event collector used to wait for metric events to occur. From c361597558b1359241f544ff8cfc917e9cce4eb1 Mon Sep 17 00:00:00 2001 From: Uddeshya Singh Date: Mon, 8 Sep 2025 18:29:27 +0530 Subject: [PATCH 2/3] Disabled flaky kill segment test --- .../druid/testing/embedded/indexing/IngestionSmokeTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java index cb23bf565cb3..ff6b58217276 100644 --- a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java +++ b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java @@ -60,6 +60,7 @@ import org.joda.time.Interval; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import java.util.ArrayList; @@ -88,7 +89,7 @@ public class IngestionSmokeTest extends EmbeddedClusterTestBase * Broker with a short metadata refresh period. */ protected EmbeddedBroker broker = new EmbeddedBroker() - .addProperty("druid.sql.planner.metadataRefreshPeriod", "PT0.1s"); + .addProperty("druid.sql.planner.metadataRefreshPeriod", "PT1s"); /** * Event collector used to wait for metric events to occur. @@ -149,6 +150,7 @@ protected int markSegmentsAsUnused(String dataSource) } @Test + @Disabled("Disabled due to flakiness after segment drops") public void test_runIndexTask_andKillData() { final int numSegments = 10; From b80ffa269bd43bdc30fc1202301f6cdec1f08e21 Mon Sep 17 00:00:00 2001 From: Uddeshya Singh Date: Mon, 8 Sep 2025 19:01:51 +0530 Subject: [PATCH 3/3] Disable the tests for only IngestionBackwardCompatibilityDockerTest --- .../docker/IngestionBackwardCompatibilityDockerTest.java | 8 ++++++++ .../testing/embedded/indexing/IngestionSmokeTest.java | 2 -- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionBackwardCompatibilityDockerTest.java b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionBackwardCompatibilityDockerTest.java index 5c814c2cb903..318e8c5c7b35 100644 --- a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionBackwardCompatibilityDockerTest.java +++ b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionBackwardCompatibilityDockerTest.java @@ -36,6 +36,7 @@ import org.jboss.netty.handler.codec.http.HttpMethod; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; /** * Runs some basic ingestion tests using Coordinator and Overlord at version @@ -85,6 +86,13 @@ public void verifyOverlordLeader() ); } + @Override + @Disabled("Disabled due to flakiness after segment drops") + public void test_runIndexTask_andKillData() + { + super.test_runIndexTask_andKillData(); + } + @Override protected int markSegmentsAsUnused(String dataSource) { diff --git a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java index ff6b58217276..668079065c4f 100644 --- a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java +++ b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java @@ -60,7 +60,6 @@ import org.joda.time.Interval; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Assertions; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import java.util.ArrayList; @@ -150,7 +149,6 @@ protected int markSegmentsAsUnused(String dataSource) } @Test - @Disabled("Disabled due to flakiness after segment drops") public void test_runIndexTask_andKillData() { final int numSegments = 10;