Hey guys, In this document : https://ci.apache.org/projects/flink/flink-docs-stable/internals/job_scheduling.html , there is a line in the beginning of the scheduling section which says that : "A pipeline consists of multiple successive tasks, such as the *n-th* parallel instance of a MapFunction together with the *n-th* parallel instance of a ReduceFunction. Note that Flink often executes successive tasks concurrently:"
I am guessing this means that Flink executes successive tasks from different pipelines successively right ? I also don't fully understand Intermediate result partition and Intermediate dataset , why are there two boxes in the diagram for intermediate result after the first execution job vertex ? Is there any more docs I can read to clearly understand these diagrams, thanks for your help. Thanks, Vishwas