becketqin commented on pull request #13784: URL: https://github.com/apache/flink/pull/13784#issuecomment-717670076
@StephanEwen @stevenzwu I have updated the patch with the following changes: 1. Move `CheckpointListener` from `flink-runtime` to `flink-core`. Because this interface is a public API, I left the existing interface class in flink-runtime but marked it as deprecated. All the usages within Apache Flink have been migrated to use the new package. 2. Let `SplitEnumerator`/`SourceReader`/`OperatorCoordinator` implement `CheckpointListener`. 3. Moving the `waitUntil()` method to `CommonTestUtils`. Would you have time to 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]
