This is an automated email from the ASF dual-hosted git repository.
FrankChen021 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 be09fa10403 Try to fix docker tests (#19416)
be09fa10403 is described below
commit be09fa1040317a2924a330b8337132c4ed655ac5
Author: Virushade <[email protected]>
AuthorDate: Wed May 6 21:20:14 2026 +0800
Try to fix docker tests (#19416)
---
.../druid/testing/embedded/indexing/IngestionSmokeTest.java | 11 +++++++++++
1 file changed, 11 insertions(+)
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 a6ed50dd7f0..089ffe2dddb 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
@@ -189,6 +189,9 @@ public class IngestionSmokeTest extends
EmbeddedClusterTestBase
.hasService("druid/broker")
);
+ waitForNextCoordinatorCacheSync();
+ waitForNextBrokerCacheSync();
+
cluster.callApi().verifySqlQuery("SELECT * FROM sys.segments WHERE
datasource='%s'", dataSource, "");
// Kill all unused segments
@@ -430,6 +433,14 @@ public class IngestionSmokeTest extends
EmbeddedClusterTestBase
);
}
+ protected void waitForNextBrokerCacheSync()
+ {
+ eventCollector.latchableEmitter().waitForNextEvent(
+ event -> event.hasMetricName("segment/metadataCache/sync/time")
+ .hasService("druid/broker")
+ );
+ }
+
/**
* Verifies the total number of used segments in {@link #dataSource}.
*/
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
