becketqin commented on pull request #12122: URL: https://github.com/apache/flink/pull/12122#issuecomment-629739829
Thanks @StephanEwen. Apologies that I somehow missed some of your previous comments... I'll merge the patch with the following changes. 1. `SourceReader` actually does not have to extend `Serializable`. So I just removed that from the interface. I also fixed other places as suggested where there is a warning. 2. Change the `CoordinatedSourceITCase` to compare the full list. ---------------------------------------------------------------- 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: us...@infra.apache.org
