I was trying to add the warning the below warning in my program.

16:56:17.958 [main] INFO  o.a.f.a.java.typeutils.TypeExtractor -- Class class com.google.protobuf.ByteString cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance and schema evolution.
16:56:17.965 [main] INFO  o.a.f.a.java.typeutils.TypeExtractor -- class com.google.protobuf.ByteString does not contain a getter for field hash
16:56:17.965 [main] INFO  o.a.f.a.java.typeutils.TypeExtractor -- class com.google.protobuf.ByteString does not contain a setter for field hash

I added code below, but didn’t help. Any suggestions of how to fix it?

val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.getConfig.registerTypeWithKryoSerializer(classOf[com.google.protobuf.ByteString],
      classOf[ProtobufSerializer])