It's not an error. It's just a bit of information from the type extractor; it still analyzes the type to check whether it is a POJO, because if it was then it wouldn't need to use Kryo. IOW, unless you experience issues with running your job, you can safely ignore it.

On 6/21/2021 9:11 PM, Debraj Manna wrote:
Hi

As mentioned in the documentation <https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/serialization/custom_serializers/> I have registered the Protobuf Serializer like below

env.getConfig().registerTypeWithKryoSerializer(SelfDescribingMessageDO.class, ProtobufSerializer.class);

It is working but I am seeing INFO logs like below

2021-06-16 06:17:22,235 INFO  org.apache.flink.api.java.typeutils.TypeExtractor 
            -class com.vnera.model.protobufs.SelfDescribingMessageDO does not 
contain a getterfor  field bitField0_

2021-06-16 06:17:22,235 INFO  org.apache.flink.api.java.typeutils.TypeExtractor 
            -class com.vnera.model.protobufs.SelfDescribingMessageDO does not 
contain a setterfor  field bitField0_

Can someone let me know why am I seeing this and how can I get around this?

Flink Version 1.13.0



Reply via email to