flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dawid Wysakowicz <dwysakow...@apache.org>
Subject Re: Changes in Flink 1.6.2
Date Fri, 30 Nov 2018 14:56:34 GMT
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.

Best,

Dawid

On 30/11/2018 15:19, Boris Lublinsky wrote:
> Dominik,
> Any feedback on this?
>
> Boris Lublinsky
> FDP Architect
> boris.lublinsky@lightbend.com <mailto:boris.lublinsky@lightbend.com>
> https://www.lightbend.com/
>
>> On Nov 28, 2018, at 2:56 PM, Boris Lublinsky
>> <boris.lublinsky@lightbend.com
>> <mailto:boris.lublinsky@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.lublinsky@lightbend.com <mailto:boris.lublinsky@lightbend.com>
>> https://www.lightbend.com/
>>
>>> On Nov 28, 2018, at 2:47 PM, Dominik Wosiński <wossyn@gmail.com
>>> <mailto:wossyn@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.lublinsky@lightbend.com
>>> <mailto:boris.lublinsky@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.lublinsky@lightbend.com <mailto:boris.lublinsky@lightbend.com>
>>>     https://www.lightbend.com/
>>>
>>
>

Mime
View raw message