This is an automated email from the ASF dual-hosted git repository.
akshat 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 568286fbd5f Fix flaky EmbeddedMsqRealtimeQueryTest (#18311)
568286fbd5f is described below
commit 568286fbd5feee9d7865862b4d7c8c20030b5c24
Author: Kashif Faraz <[email protected]>
AuthorDate: Wed Jul 23 16:19:04 2025 +0530
Fix flaky EmbeddedMsqRealtimeQueryTest (#18311)
---
.../druid/testing/embedded/msq/EmbeddedMSQRealtimeQueryTest.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/msq/EmbeddedMSQRealtimeQueryTest.java
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/msq/EmbeddedMSQRealtimeQueryTest.java
index c2433b86bf3..f10cab7a268 100644
---
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/msq/EmbeddedMSQRealtimeQueryTest.java
+++
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/msq/EmbeddedMSQRealtimeQueryTest.java
@@ -176,6 +176,9 @@ public class EmbeddedMSQRealtimeQueryTest extends
BaseRealtimeQueryTest
.hasDimension(DruidMetrics.DATASOURCE,
Collections.singletonList(dataSource)),
agg -> agg.hasSumAtLeast(totalRows)
);
+ broker.latchableEmitter().waitForEvent(
+ event -> event.hasDimension(DruidMetrics.DATASOURCE, dataSource)
+ );
}
@Test
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
