[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354777#comment-17354777 ]
wangwj commented on FLINK-10205: -------------------------------- [~Ryantaocer][~isunjin] Hi, excuse me. After I read this issue detailed, I have a question that in batch job although each inputsplit will be processed exactly once, but when a task failover, it maybe not process the same inputsplit before failover after this patch merged. Does this problem still exist? I am working in speculative execution, so I want to discuess with you. Thanks~ > Batch Job: InputSplit Fault tolerant for DataSourceTask > ------------------------------------------------------- > > Key: FLINK-10205 > URL: https://issues.apache.org/jira/browse/FLINK-10205 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Coordination > Affects Versions: 1.6.1, 1.6.2, 1.7.0 > Reporter: JIN SUN > Assignee: ryantaocer > Priority: Major > Labels: pull-request-available > Fix For: 1.9.0 > > Original Estimate: 168h > Time Spent: 0.5h > Remaining Estimate: 167.5h > > Today DataSource Task pull InputSplits from JobManager to achieve better > performance, however, when a DataSourceTask failed and rerun, it will not get > the same splits as its previous version. this will introduce inconsistent > result or even data corruption. > Furthermore, if there are two executions run at the same time (in batch > scenario), this two executions should process same splits. > we need to fix the issue to make the inputs of a DataSourceTask > deterministic. The propose is save all splits into ExecutionVertex and > DataSourceTask will pull split from there. > document: > [https://docs.google.com/document/d/1FdZdcA63tPUEewcCimTFy9Iz2jlVlMRANZkO4RngIuk/edit?usp=sharing] -- This message was sent by Atlassian Jira (v8.3.4#803005)