Hi Prashant,
Flink should always give warnings as long as the deduced result
is GenericType, no matter it uses the default kryo serializer or
the register one, thus if you have registered the type, you may
simply ignore the warnings. To make sure it works, you may
find the tm that the source ta
so i did register the type with Kryo and the ProtobufSerializer. However I am
still continuing to see the warnings. is this a bug in Flink?
env.config.registerTypeWithKryoSerializer(Trace.APITrace:: class.java (
http://class.java/ ) , ProtobufSerializer:: class.java ( http://class.java/ ) )
va
Hi Prashant,
I think the warn is given when calling
return TypeInformation.of(Trace.APITrace::class.java)
Currently flink does not have the native support
for the protobuf types yet[1], thus it would use a
generic serializer created by kryo.
This should not affect the rightness of the progra
