FrankChen021 opened a new pull request, #20124: URL: https://github.com/apache/druid/pull/20124
### Description `KafkaBoundedSupervisorTest` can exceed the embedded cluster's default 60-second latch timeout while a bounded supervisor starts tasks, consumes records, and publishes segments. The post-merge CI run for PR [#20106](https://github.com/apache/druid/pull/20106) provides the evidence: - The `Unit & Integration tests CI` run [32516481844](https://github.com/apache/druid/actions/runs/32516481844) failed in job [96879148560](https://github.com/apache/druid/actions/runs/32516481844/job/96879148560). - The failed JDK 25 shard timed out in `KafkaBoundedSupervisorTest.test_boundedSupervisor_doesNotSilentlyCompleteWhenStaleOffsetExceedsNewEnd` while waiting for 250 published records. - The same shard passed before merge in PR #20106. - PR [#19543](https://github.com/apache/druid/pull/19543) previously addressed the same cold-start timing issue by using a 120-second wait for one bounded-supervisor ingestion path. This change: - Applies a 120-second maximum wait to the bounded-supervisor ingestion waits. The timeout is a ceiling, not a fixed delay. - Uses `maxRowsPerSegment = 100` for this test class instead of the shared fixture's one-row segments. This reduces segment rollover and publication overhead while preserving the test's offset, row-count, and supervisor-state assertions. There is no user-facing behavior change. #### Release note No user-facing behavior change. <hr> ##### Key changed/added classes in this PR * `KafkaBoundedSupervisorTest` <hr> This PR has: - [x] been self-reviewed. - [x] modified an existing test to cover the affected CI timing path. - [ ] added documentation for new or modified features or behaviors. - [x] a release note entry in the PR description (test-only change). - [ ] added or updated version, license, or notice information in `licenses.yaml`. Local verification: ```text mvn test -pl embedded-tests -am -Dtest=org.apache.druid.testing.embedded.indexing.KafkaBoundedSupervisorTest -Dsurefire.failIfNoSpecifiedTests=false -Pskip-static-checks -Dweb.console.skip=true -T1 ``` Result: 6 tests passed; Maven reactor `BUILD SUCCESS`. -- 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]
