tillrohrmann removed a comment on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#issuecomment-431790382 @isunjin I agree that the current implementation does not work with region failover. The thing I'm questioning is whether the `InputSplits` of the failed task need to be processed by the same (restarted) task or can be given to any running task. So far I'm not convinced that something would break if we simply return the `InputSplits` to the `InputSplitAssigner`. I think the `WordCount` example should work with this. Before hotfixing something in a way that might hurt us in the future, I would really like to grasp the full picture of why you want to solve the problem that way.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
