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:
[email protected]


Reply via email to