I am using String inside to convert into bytes.
On Thu, Feb 23, 2017 at 6:50 PM, 刘彪 <mmyy1...@gmail.com> wrote:
> 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 <mohitanch...@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(ObjectOutputSt
>> ream.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
>>
>>
>>
>>
>
