You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by "xiangfu0 (via GitHub)" <gi...@apache.org> on 2026/08/29 09:16:08 UTC
[I] [MSE] Support sender-side sorting for sort exchanges [pinot]
xiangfu0 opened a new issue, #19395:
URL: https://github.com/apache/pinot/issues/19395
## Problem
`PinotLogicalSortExchange` currently sorts only on the receiver. Operators such as WINDOW and MATCH_RECOGNIZE therefore require the receiver to buffer and sort the complete exchanged input instead of merging already sorted sender streams.
## Proposed scope
- Add sender-side sorting using the exchange collation, including direction and null ordering.
- Merge sorted mailbox streams incrementally on the receiver with bounded memory.
- Preserve cancellation, deadline, backpressure, and error propagation behavior.
- Add distributed tests covering multiple senders, duplicate keys, nulls, and empty streams.
## Context
Follow-up to #19311 and the existing receiver-side-only note in `PinotWindowExchangeNodeInsertRule`.
--
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@pinot.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org