flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 刘彪 <mmyy1...@gmail.com>
Subject Re: Serialization schema
Date Fri, 24 Feb 2017 02:50:20 GMT
Hi Mohit
As you did not give the whole codes of Tuple2Serializerr. I guess the
reason is some fields of Tuple2Serializerr do not implement Serializable.

2017-02-24 9:07 GMT+08:00 Mohit Anchlia <mohitanchlia@gmail.com>:

> I wrote a key serialization class to write to kafka however I am getting
> this error. Not sure why as I've already implemented the interfaces.
>
> Caused by: java.io.NotSerializableException: com.sy.flink.test.
> Tuple2Serializerr$1
>         at java.io.ObjectOutputStream.writeObject0(
> ObjectOutputStream.java:1184)
>         at java.io.ObjectOutputStream.defaultWriteFields(
> ObjectOutputStream.java:1548)
>
> And the class implements the following:
>
> *public* *class* *Tuple2Serializerr* *implements*
>
> DeserializationSchema<Tuple2<Integer, Integer>>,
>
> SerializationSchema<Tuple2<Integer, Integer>> {
>
> And called like this:
>
>
> FlinkKafkaProducer010<Tuple2<Integer, Integer>> myProducer = *new*
> FlinkKafkaProducer010<Tuple2<Integer, Integer>>(
>
> "10.22.4.15:9092", // broker list
>
> "my-topic", // target topic
>
> *new* Tuple2Serializerr()); // serialization schema
>
>
>
>

Mime
View raw message