gortiz commented on code in PR #16919: URL: https://github.com/apache/pinot/pull/16919#discussion_r2390041616
########## pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/MailboxContentObserver.java: ########## Review Comment: It is. The early terminated state means the receiving operator will discard future data blocks, but it is waiting for the EOS block (either success or error). When the sender sends that EOS, the receiver is going to add that to the mailbox and that will originate another Status message (the ones that go from receiver to message), so we need to keep the channel open until that EOS is received -- 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]
