flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] tillrohrmann commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…
Date Mon, 22 Oct 2018 07:12:02 GMT
tillrohrmann commented on issue #6684:     [FLINK-10205] Batch Job: InputSplit Fault tolerant
for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-431757055
 
 
   @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:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message