flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ferenc Turi <turifs...@gmail.com>
Subject Re: nosuchmethoderror
Date Wed, 02 Sep 2015 19:04:18 GMT
Ok. As I see only the method name was changed. It was an unnecessary
modification which caused the incompatibility.

F.

On Wed, Sep 2, 2015 at 8:53 PM, Márton Balassi <balassi.marton@gmail.com>
wrote:

> Dear Ferenc,
>
> The Kafka consumer implementations was modified from 0.9.0 to 0.9.1,
> please use the new code. [1]
>
> I suspect that your com.nventdata.kafkaflink.sink.FlinkKafkaTopicWriterSink
> depends on the way the Flink code used to look in 0.9.0, if you take a
> closer look Robert changed the function that is missing in your error in
> [1].
>
> [1]
> https://github.com/apache/flink/commit/940a7c8a667875b8512b63e4a32453b1a2a58785
>
> Best,
>
> Márton
>
> On Wed, Sep 2, 2015 at 8:47 PM, Ferenc Turi <turifster@gmail.com> wrote:
>
>> Hi,
>>
>> I tried to use the latest 0.9.1 release but I got:
>>
>> java.lang.NoSuchMethodError:
>> org.apache.flink.util.NetUtils.ensureCorrectHostnamePort(Ljava/lang/String;)V
>> at
>> com.nventdata.kafkaflink.sink.FlinkKafkaTopicWriterSink.<init>(FlinkKafkaTopicWriterSink.java:69)
>> at
>> com.nventdata.kafkaflink.sink.FlinkKafkaTopicWriterSink.<init>(FlinkKafkaTopicWriterSink.java:48)
>> at
>> com.nventdata.kafkaflink.FlinkKafkaTopicWriterMain.main(FlinkKafkaTopicWriterMain.java:54)
>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>> at
>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
>> at
>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>> at java.lang.reflect.Method.invoke(Method.java:606)
>> at
>> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:437)
>> at
>> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353)
>> at org.apache.flink.client.program.Client.run(Client.java:315)
>> at
>> org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:582)
>> at org.apache.flink.client.CliFrontend.run(CliFrontend.java:288)
>> at
>> org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:878)
>> at org.apache.flink.client.CliFrontend.main(CliFrontend.java:920)
>>
>>
>> Thanks,
>>
>> Ferenc
>>
>
>


-- 
Kind Regards,

Ferenc

Mime
View raw message