(DEPRECATED) Apache Flink User Mailing List archive.

nosuchmethoderror

classic Classic list List threaded Threaded
♦
♦
 4 messages Options
turif
Reply | Threaded
Open this post in threaded view
♦
♦
|

nosuchmethoderror

turif
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
Márton Balassi
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: nosuchmethoderror

Márton Balassi
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]. 


Best,

Márton

On Wed, Sep 2, 2015 at 8:47 PM, Ferenc Turi <[hidden email]> 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
turif
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: nosuchmethoderror

turif
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 <[hidden email]> 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]. 


Best,

Márton

On Wed, Sep 2, 2015 at 8:47 PM, Ferenc Turi <[hidden email]> 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
rmetzger0
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: nosuchmethoderror

rmetzger0
I'm sorry that we changed the method name between minor versions.

We'll soon bring some infrastructure in place a) mark the audience of classes and b) ensure that public APIs are stable.

On Wed, Sep 2, 2015 at 9:04 PM, Ferenc Turi <[hidden email]> wrote:
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 <[hidden email]> 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]. 


Best,

Márton

On Wed, Sep 2, 2015 at 8:47 PM, Ferenc Turi <[hidden email]> 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
Free forum by Nabble Edit this page