Dominik,
Any feedback on this?
Boris Lublinsky
FDP Architect
boris.lublin...@lightbend.com
https://www.lightbend.com/
> On Nov 28, 2018, at 2:56 PM, Boris Lublinsky <boris.lublin...@lightbend.com>
> 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
> boris.lublin...@lightbend.com <mailto:boris.lublin...@lightbend.com>
> https://www.lightbend.com/
>
>> On Nov 28, 2018, at 2:47 PM, Dominik Wosiński <wos...@gmail.com
>> <mailto:wos...@gmail.com>> wrote:
>>
>> Hey,
>> Could you show the message that You are getting?
>> Best Regards,
>> Dom.
>>
>> śr., 28 lis 2018 o 19:08 Boris Lublinsky <boris.lublin...@lightbend.com
>> <mailto:boris.lublin...@lightbend.com>> 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
>> boris.lublin...@lightbend.com <mailto:boris.lublin...@lightbend.com>
>> https://www.lightbend.com/ <https://www.lightbend.com/>
>
