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 JobVert
omProgram(this.program, this.args);
}
return this.plan;
}
-Original Message-
From: "Ufuk Celebi"<u...@apache.org>
To: <user@flink.apache.org>; "윤형덕"<ynoo...@naver.com>;
Cc:
Sent: 2016-05-20 (금) 19:30:01
Subject: Re: inheritance of Program interf
hello first I'm sorry for my poor english.
I were looking at PackagedProgram.java from org.apache.flink.client.program
and in following cunstructor: PackagedProgram(File jarFile, List classpaths,
String entryPointClassName, String... args)
there is some code I couldn't understand. please look