PatrickRen commented on pull request #15461: URL: https://github.com/apache/flink/pull/15461#issuecomment-811805546
Thanks @becketqin and @StephanEwen! Since several bugs and improvements have been mentioned in this PR, I would like to split them into multiple commits: - Remove split assignment tracking from Kafka enumerator 36d41e3 - Signal NoMoreSplitsEvent to readers without assignment d70617219a17dc5e14f4edc258ba441dc122bb96 , and there's already a ticket for it (see FLINK-21159), and also close #14789 These two are critical issues, so I worked on them first. Another issue is about - Refactoring logic of discovering and assigning splits in worker and coordinator thread. This is a relatively big change. I'll continue working on it, but not quite a blocker for now. @StephanEwen @becketqin Could you please have a review for the first two commits? 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]
