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 :
> I wrote a key serialization class to write to kafka however I am getting
> this error. Not sure why
ype of outputformat?
>
> On Tue, Feb 21, 2017 at 7:13 PM, 刘彪 wrote:
>
>> Hi
>> I think there is a good way in FlinkKafkaProducerBase.java to deal with
>> this situation. There is a KeyedSerializationSchema user have to implement.
>> KeyedSerializationSchema
Hi
I think there is a good way in FlinkKafkaProducerBase.java to deal with
this situation. There is a KeyedSerializationSchema user have to implement.
KeyedSerializationSchema will be used to serialize data, so that
SinkFunction just need to understand the type after serialization.
In your case,
In AbstractRocksDBState.writeKeyAndNamespace():
protected void writeKeyAndNamespace(DataOutputView out) throws IOException {
backend.keySerializer().serialize(backend.currentKey(), out);
out.writeByte(42);
namespaceSerializer.serialize(currentNamespace, out);
}
Why write a byte 42 between key and
