FrankChen021 opened a new issue, #20817: URL: https://github.com/apache/druid/issues/20817
_This issue was generated automatically by Claude Code (Anthropic's AI coding agent) running a scheduled CI-triage routine on behalf of @FrankChen021. Analysis and suggested fixes are AI-produced; please verify before acting on them._ **Status:** Open: no fix PR **Subject:** `KafkaMultiSupervisorTest.test_ingestIntoSingleDatasource_fromDifferentTopics` (embedded-tests, `unit tests / unit tests(main) (25, K*,U*,Z*,Y*,X*)`) **Failures:** 1 · **First seen:** 2026-11-01 · **Last seen:** 2026-11-01 ### Root cause With `useTransactions=true` (parameter `[1]`), the sum of `ingest/rows/published` for the datasource did not reach 3000 within the 60 s default wait (`KafkaMultiSupervisorTest.java:86` → `StreamIndexTestBase.waitUntilPublishedRecordsAreIngested:164`). `createKafkaSupervisor` sets `maxRowsPerSegment(1)`, so the two supervisors' tasks push, publish and hand off roughly one segment per row into the same datasource and interval, contending on the Overlord's segment allocation and publish paths; the non-transactional variant passed in the same run. The failing commit (#20807) only excludes `node_modules` from the Docker build context, and the same job passed on the next master commit (9a36f0ec70). ### Suggested fix Override `withTuningConfig(t -> t.withMaxRowsPerSegment(1000))` in this test (it only checks per-topic row counts), or use the `waitUntilPublishedRecordsAreIngested(totalRowCount, 120_000L)` overload. ### Occurrences Failed push-triggered master jobs only. The daily triage routine adds one row per new failed job. | Date | Commit | Job | Failure log | Detail | Reported in | |---|---|---|---|---|---| | 2026-11-01 | 88d68cac1d (#20807) | `unit tests / unit tests(main) (25, K*,U*,Z*,Y*,X*) / test-jdk25-[K*,U*,Z*,Y*,X*]` | [job 124725198050](https://github.com/apache/druid/actions/runs/41264781389/job/124725198050) | `ISE: Timed out waiting for event after [60,000]ms` for 3000 published rows, `useTransactions=true` (`[1]`); 1/1 attempt | | -- 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]
