Re: nosuchmethoderror

2015-09-02 Thread Ferenc Turi
tps://github.com/apache/flink/commit/940a7c8a667875b8512b63e4a32453b1a2a58785 > > Best, > > Márton > > On Wed, Sep 2, 2015 at 8:47 PM, Ferenc Turi wrote: > >> Hi, >> >> I tried to use the latest 0.9.1 release but I got: >> >> java.lang.NoSuchMethodError:

nosuchmethoderror

2015-09-02 Thread Ferenc Turi
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.(FlinkKafkaTopicWriterSink.java:69) at com.nventdata.kafkaflink.sink.FlinkKa

Kafka avro recordschema serializing / deserializing

2015-08-29 Thread Ferenc Turi
Hi, I tried to read avro (RecordSchema) data from Kafka using the flink-kafka connector but I have problems: Exception says at program startup: Caused by: java.io.NotSerializableException: org.apache.avro.Schema$RecordSchema at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java