Page History

...

Based on FLINK-10205, we could ensure ....

simply return the InputSplits to the InputSplitAssigner also implies transaction between task and jobManager (maybe multiple one), we need to make sure the inputSplits get return to the InputSplitAssigner exactly once. what happened if we have speculative execution, which means two task consume the same set of InputSplits and but not fail at same time, does every InputSplitAssigner need to keep a list to deduplicate? what happened if the TM died or has network issue and InputSplit cannot be return?

这个pr里面的讨论，要说一下，https://github.com/apache/flink/pull/6684

Manage middle ResultPartition 

...