[GitHub] [pinot] 61yao opened a new issue, #9789: [multistage] GrpcSendingMailbox init won't stop on exception

[GitBox <gi...@apache.org>]

61yao opened a new issue, #9789:
URL: https://github.com/apache/pinot/issues/9789

   This is happening on MailboxSendOperator getNextBlock().
   When sendDataTableBlock is called the first time, send is called on GrpcSendingMailbox. 
   
   GrpcSendingMailbox.send() will call GrpcSendingMailbox.init(), which will call _statusStreamObserver.send(MAILBOX_METADATA_BEGIN_OF_STREAM_KEY).
   
   If _statusStreamObserver.send() throws an exception, _initialized will not be set to true. This exception is logged in MailboxSendOperator.getNextBlock() and not passed to upstream. 
   
   Next time the send is called, init will be called again till mailbox send times out 
    


-- 
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