Here is the code
def executeLocal() : Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
buildGraph(env)
System.out.println("[info] Job ID: " +
env.getStreamGraph.getJobGraph.getJobID)
env.execute()
}
And an error
Error:(68, 63) ambiguous reference to overloaded definition,
both method getJobGraph in class StreamGraph of type (x$1:
org.apache.flink.api.common.JobID)org.apache.flink.runtime.jobgraph.JobGraph
and method getJobGraph in class StreamingPlan of type
()org.apache.flink.runtime.jobgraph.JobGraph
match expected type ?
System.out.println("[info] Job ID: " +
env.getStreamGraph.getJobGraph.getJobID)
Boris Lublinsky
FDP Architect
[email protected]
https://www.lightbend.com/
> On Nov 28, 2018, at 2:47 PM, Dominik Wosiński <[email protected]> wrote:
>
> Hey,
> Could you show the message that You are getting?
> Best Regards,
> Dom.
>
> śr., 28 lis 2018 o 19:08 Boris Lublinsky <[email protected]
> <mailto:[email protected]>> napisał(a):
>
>
>
> Prior to Flink version 1.6.2 including 1.6.1
> env.getStreamGraph.getJobGraph was happily returning currently defined Graph,
> but in 1.6.2 this fails to compile with a pretty cryptic message
> AM I missing something?
>
>
> Boris Lublinsky
> FDP Architect
> [email protected] <mailto:[email protected]>
> https://www.lightbend.com/ <https://www.lightbend.com/>
