Hi , I think there is no difference between JobVertex(A) and JobVertex(B). Because the JobVertex(C) is not shown in the right graph, it may mislead you.There should be another intermediate result partition between JobVertex(B) and JobVertex(C) for each parallelism, and that is the same case with JobVertex(A).
Cheers, Zhijiang------------------------------------------------------------------发件人：윤형덕 <ynoo...@naver.com>发送时间：2017年3月13日(星期一) 12:43收件人：user <user@flink.apache.org>主 题：multiple consumer of intermediate data set Hi All, figure1 https://ci.apache.org/projects/flink/flink-docs-release-1.2/fig/job_and_execution_graph.svg as we can see in figure1, JobVertex(B) has two consumer( JobVertex(C) and JobVertex(D) )and accordingly Intermediate Data Set of JobVertex(B) has two consumer( JobVertex(C) and JobVertex(D) ) but in case of JobVertex(A), though it has two consumer( JobVertex(B) and JobVertex(D) ) same as JobVertex(B)it has two separate intermediates data set and each intermediate data set has one consumer. i couldn't understand why... for me it looks same case but why one has one Intermediate Data Set and another has two? could anyone explain what is difference between JobVertex(A) and JobVertex(B)?
