1996fanrui commented on PR #22968: URL: https://github.com/apache/flink/pull/22968#issuecomment-1625479722
Hi @RocMarshal @mas-chen , this is the backporting of FLINK-32496 for release-1.16. Could you help take a look this PR in your free time? thanks~ 1.16 has a little conflicts with 1.17 and master, `SourceOperator` doesn't implement the `imestampsAndWatermarks.WatermarkUpdateListener` in `1.16`. I implemented it to compatible with this fix. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
