amaechler opened a new pull request, #19581: URL: https://github.com/apache/druid/pull/19581
`EmbeddedKafkaSupervisorTest.test_runKafkaSupervisor` is flaky in CI: ``` EmbeddedKafkaSupervisorTest.test_runKafkaSupervisor:129 expected: <10> but was: <8> ``` (observed values 7–9 across retries) The test produces 10 records, waits only for the broker to discover the datasource (the first matching metric event), then immediately asserts `SELECT COUNT(*) == 10`. Under a loaded CI runner the query races ingestion and observes fewer than 10 rows. This adds a wait on `ingest/events/processed` reaching the expected count before the row-count assertion identical to what `test_runSupervisor_withEmptyDimension` in this file already uses. <hr> This PR has: - [x] been self-reviewed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
