Re: Changes in Flink 1.6.2

2018-11-30 Thread Dominik Wosiński
Hey, @Dawid is right. It is a known issue in Scala. This is due to the functional nature of Scala and is explained on StackOverflow[1]. Best Regards, Dom. [1] https://stackoverflow.com/questions/7498677/why-is-this-reference-ambiguous pt., 30 lis 2018 o 15:56 Dawid Wysakowicz napisał(a): > Hi

Re: Changes in Flink 1.6.2

2018-11-30 Thread Boris Lublinsky
It does, weird Boris Lublinsky FDP Architect boris.lublin...@lightbend.com https://www.lightbend.com/ > On Nov 30, 2018, at 8:56 AM, Dawid Wysakowicz wrote: > > Hi Boris, > > I am not a scala expert, so I won't be able explain the root cause > completely, but it is because you access empty-pa

Re: Changes in Flink 1.6.2

2018-11-30 Thread Dawid Wysakowicz
Hi Boris, I am not a scala expert, so I won't be able explain the root cause completely, but it is because you access empty-parameter java method as scala parameterless one (I don't know why it doesn't work). If you change your code to: env.getStreamGraph.getJobGraph().getJobID it will work. Bes

Re: Changes in Flink 1.6.2

2018-11-30 Thread Boris Lublinsky
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 > wrote: > > Here is the code > > def executeLocal() : Unit = { > val env = StreamExecutionEnvironment.getExecutionEnvironment

Re: Changes in Flink 1.6.2

2018-11-28 Thread Boris Lublinsky
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 defini

Re: Changes in Flink 1.6.2

2018-11-28 Thread Dominik Wosiński
Hey, Could you show the message that You are getting? Best Regards, Dom. śr., 28 lis 2018 o 19:08 Boris Lublinsky 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

Changes in Flink 1.6.2

2018-11-28 Thread Boris Lublinsky
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 https://www.lightbend