This is an automated email from the ASF dual-hosted git repository.

kfaraz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git


The following commit(s) were added to refs/heads/master by this push:
     new 77f26304b43 fix: embedded-tests start metric event collector early so 
logs are less noisy (#20056)
77f26304b43 is described below

commit 77f26304b4355c537b753fb034df9cb8d7da8a1b
Author: Clint Wylie <[email protected]>
AuthorDate: Thu Aug 20 21:24:29 2026 -0700

    fix: embedded-tests start metric event collector early so logs are less 
noisy (#20056)
---
 .../embedded/docker/IngestionBackwardCompatibilityDockerTest.java       | 2 +-
 .../org/apache/druid/testing/embedded/docker/IngestionDockerTest.java   | 2 +-
 .../org/apache/druid/testing/embedded/indexing/IngestionSmokeTest.java  | 2 +-
 .../apache/druid/testing/embedded/k8s/KubernetesClusterDockerTest.java  | 2 +-
 4 files changed, 4 insertions(+), 4 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 00912129fd2..3b37ec999d1 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
@@ -65,6 +65,7 @@ public class IngestionBackwardCompatibilityDockerTest extends 
IngestionSmokeTest
     return cluster
         .useContainerFriendlyHostname()
         .useDefaultTimeoutForLatchableEmitter(60)
+        .addServer(eventCollector)
         .addResource(containerOverlord)
         .addResource(containerCoordinator)
         .addServer(overlord)
@@ -72,7 +73,6 @@ public class IngestionBackwardCompatibilityDockerTest extends 
IngestionSmokeTest
         .addServer(broker)
         .addServer(new EmbeddedHistorical())
         .addServer(new EmbeddedRouter())
-        .addServer(eventCollector)
         .addCommonProperty(
             "druid.extensions.loadList",
             "[\"druid-s3-extensions\", \"druid-kafka-indexing-service\","
diff --git 
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionDockerTest.java
 
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionDockerTest.java
index 4cc4296efac..9c5742a5238 100644
--- 
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionDockerTest.java
+++ 
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/docker/IngestionDockerTest.java
@@ -54,6 +54,7 @@ public class IngestionDockerTest extends IngestionSmokeTest 
implements LatestIma
     return cluster
         .useDefaultTimeoutForLatchableEmitter(240)
         .useContainerFriendlyHostname()
+        .addServer(eventCollector)
         .addResource(containerOverlord)
         .addResource(containerCoordinator)
         .addResource(middleManager)
@@ -61,7 +62,6 @@ public class IngestionDockerTest extends IngestionSmokeTest 
implements LatestIma
         .addResource(router)
         .addServer(overlord)
         .addServer(broker)
-        .addServer(eventCollector)
         .addCommonProperty(
             "druid.extensions.loadList",
             "[\"druid-s3-extensions\", \"druid-kafka-indexing-service\","
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 e9033a5375a..d703325ce6e 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
@@ -133,11 +133,11 @@ public class IngestionSmokeTest extends 
EmbeddedClusterTestBase
   protected EmbeddedDruidCluster addServers(EmbeddedDruidCluster cluster)
   {
     return cluster
+        .addServer(eventCollector)
         .addServer(new EmbeddedCoordinator())
         .addServer(overlord)
         .addServer(indexer)
         .addServer(broker)
-        .addServer(eventCollector)
         .addServer(new EmbeddedHistorical())
         .addServer(new EmbeddedRouter());
   }
diff --git 
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/k8s/KubernetesClusterDockerTest.java
 
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/k8s/KubernetesClusterDockerTest.java
index 35c3f08f330..11cc4cf3b2e 100644
--- 
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/k8s/KubernetesClusterDockerTest.java
+++ 
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/k8s/KubernetesClusterDockerTest.java
@@ -56,10 +56,10 @@ public class KubernetesClusterDockerTest extends 
IngestionSmokeTest implements L
     return cluster
         .useContainerFriendlyHostname()
         .useDefaultTimeoutForLatchableEmitter(60)
+        .addServer(eventCollector)
         .addResource(k3sCluster)
         .addServer(overlord)
         .addServer(broker)
-        .addServer(eventCollector)
         .addCommonProperty(
             "druid.extensions.loadList",
             "[\"druid-s3-extensions\", \"druid-kafka-indexing-service\", 
\"postgresql-metadata-storage\"]"


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to