[GitHub] [flink] StephanEwen commented on pull request #13366: [FLINK-17393][connector/common] Wakeup the SplitFetchers more elegantly.
StephanEwen commented on pull request #13366: URL: https://github.com/apache/flink/pull/13366#issuecomment-692355604 I incorporated this PR in a follow-up PR with some more changes and bug fixes: #13385 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
[GitHub] [flink] StephanEwen commented on pull request #13366: [FLINK-17393][connector/common] Wakeup the SplitFetchers more elegantly.
StephanEwen commented on pull request #13366: URL: https://github.com/apache/flink/pull/13366#issuecomment-692021999 Thanks @becketqin for creating this patch. This looks pretty good to me. I will rebase this onto the latest source API classes and merge this. Will also apply some minor cleanups that are made possible now with this fix (like removing some interruption clearing and some exceptions from signatures). 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