Dominik, Any feedback on this? Boris Lublinsky FDP Architect [email protected] https://www.lightbend.com/
> On Nov 28, 2018, at 2:56 PM, Boris Lublinsky <[email protected]> > wrote: > > 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] <mailto:[email protected]> > https://www.lightbend.com/ > >> On Nov 28, 2018, at 2:47 PM, Dominik Wosiński <[email protected] >> <mailto:[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/> >
