becketqin commented on pull request #12002: URL: https://github.com/apache/flink/pull/12002#issuecomment-625853562
@StephanEwen I just updated the patch with the following changes. * Combined the SplitSerializerVersion with the SplitState. * Replaced `WithOperatorCoordinator` with `CoordinatedOperatorFactory`. The caveat is that we can only tell the implementations to return a `OperatorEventHandler` from `createStreamOperator()`. This seems the best we can do for now. Can you take another look? Thanks! ---------------------------------------------------------------- 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]
