You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/05/27 11:53:34 UTC

[GitHub] [flink] pnowojski commented on pull request #12292: [FLINK-17861][task][checkpointing] Split channel state handles sent to JM

pnowojski commented on pull request #12292:
URL: https://github.com/apache/flink/pull/12292#issuecomment-634609613


   My questions probing in the direction of single channel state handle seems to be going in a very similar direction as the alternate solution that you proposed: moving the shared `StreamStateHandle` one level up, but also additionally encapsulating them into something, for example:
   
   ```
   Each subtask reports to JM TaskStateSnapshot, 
       each with zero ore more OperatorSubtaskState,
           each with zero or one InFlightDataStateHandle
               each with one StreamStateHandle
               each with zero or more InputChannelStateHandle and ResultSubpartitionStateHandle
   ```
   


----------------------------------------------------------------
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:
users@infra.apache.org