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:
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
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