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
