davecromberge opened a new pull request, #19323: URL: https://github.com/apache/pinot/pull/19323
`ReceivingMailbox.registerReader` only assigned the reader. If a sender had already offered data or EOS, the earlier `notifyReader()` found no reader and the wake-up was dropped, so the reader blocked until the query deadline and the query failed with `EXECUTION_TIMEOUT` (250). Reachable whenever a sender completes before the receiving stage registers — most easily on the in-memory path, where a leaf worker co-located with the consuming stage can finish in ~1ms. Observed in production on a `count(*)` that otherwise takes single-digit ms. `registerReader` now delivers the pending wake-up if blocks or EOS are already buffered, under the existing lock. Three tests cover data-before-registration, EOS-before-registration, and the empty-mailbox case (must not notify). -- 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]
