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 <turifs...@gmail.com> 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 <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 > > >
