You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by "FrankChen021 (via GitHub)" <gi...@apache.org> on 2026/08/22 04:29:47 UTC
[PR] test: harden bounded Kafka supervisor timeouts (druid)
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: commits-unsubscribe@druid.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org
Re: [PR] test: harden bounded Kafka supervisor timeouts (druid)
Posted by "FrankChen021 (via GitHub)" <gi...@apache.org>.
FrankChen021 merged PR #20124:
URL: https://github.com/apache/druid/pull/20124
--
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: commits-unsubscribe@druid.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org