AHeise commented on issue #9383: [FLINK-13248] [runtime] Adding processing of 
downstream messages in AsyncWaitOperator's wait loops
URL: https://github.com/apache/flink/pull/9383#issuecomment-521938038
   > > Implementation wise, it looks like the main (task level) mailbox 
(`TaskMailboxImpl`) became an implicit delegate of mailbox of operator at index 
   > > Instead, I think, it still could be a proper mailbox that can allow 
executing any letters. In particular, some timer triggers and checkpoints are 
operator neutral. They still could progress independently of operators.
   > > It may require, to adjust this implementation, to also execute letters 
that are not addressed directly to downstream operators. (It's possible also to 
place such letters as `Mail` with operator index `MAX_INT`).
   > Yes, MAX_INT makes more sense than 0 in any case. That was actually my 
original intent.
   After some discussions, we moved it to -1 instead and just treat priority 
mail with MAX_INT.

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.
For queries about this service, please contact Infrastructure at:

With regards,
Apache Git Services

Reply via email to