StephanEwen edited a comment on pull request #15601:
URL: https://github.com/apache/flink/pull/15601#issuecomment-820502234
About the "ready signatures": If we can make signature 1 work well without
much complication, I find it easier to understand.
For the uses we have right now, the coordinator anyways waits for another
event (like RegisterReader) before starting.
If we see that we need other cases in the future, we can do one of two
things, which are easy changes:
- Ensure that events are queued on the TM side as soon as the task is in
INITIALIZING state, meaning that while the AbstractInvokable isn't yet
constructed, the events are queued and later disatched.
- Changing the coordinator to go to ready only in RUNNING. If an event
comes before that, we pre-maturely switch it to RUNNING and after that dispatch
the event, meaning we call `subtaskReady()` directly followed by
`handleOperatorEvent()`.
Both look like changes that are extensions of this solution here, meaning
this solution works as a good base and we don't have to change everything
again. That's why I would like to go with this solution now.
--
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]
