<user@flink.apache.org>; Zhijiang(wangzhijiang999)
<wangzhijiang...@aliyun.com>主 题:Re: multiple consumer of intermediate data set
Hi, if output is same, why not just only one intermediate data set is ok
2017-03-14 14:36 GMT+08:00 Zhijiang(wangzhijiang999)
<wangzhijiang...@aliyun.co
-
> 发件人:윤형덕 <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/
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
For context, this is from the Flink doc:
https://ci.apache.org/projects/flink/flink-docs-release-1.3/internals/job_scheduling.html
I think Ufuk (cc-ed) could know more about this>
On Mon, Mar 13, 2017, at 05:42, 윤형덕 wrote:
> Hi All,
>
> figure1
>
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