StephanEwen commented on pull request #15601: URL: https://github.com/apache/flink/pull/15601#issuecomment-819622791
I updated to PR to signal the `SourceCoordinator` with `subtaskReady(...)` when the task goes to `INITIALIZING`. That seems to work well. I think it makes sense. Tasks are really ready from the communication perspective when they enter `INITIALIZING`, and part of the work happens there (like you mentioned, `StreamOperator.open()` happens there). Before I rebased, it worked and made sense, because `RUNNING` wasn't yet split into `INITIALIZING` and `RUNNING`. Now we have the same behavior: as soon as we enter the states that previously mapped to `RUNNING`, we signal "go!". -- 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]
