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.mar...@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 <turifs...@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
