Gabriele Lorencini created FLINK-24102:
------------------------------------------
Summary: unknown Fields error when flink doesn't recognize a field
on protobuf
Key: FLINK-24102
URL: https://issues.apache.org/jira/browse/FLINK-24102
Project: Flink
Issue Type: Bug
Reporter: Gabriele Lorencini
Using KryoSerializer for deserialize messages of kafka in Array[bytes], flink
return an error with unknown fields and its necessary declare the two class
below :
Class<?> unmodColl =
Class.forName("java.util.Collections$UnmodifiableCollection");
Class<?> unmodColl2 = Class.forName("java.util.Collections$UnmodifiableMap");
env.getConfig().addDefaultKryoSerializer(unmodColl,
UnmodifiableCollectionsSerializer.class);
env.getConfig().addDefaultKryoSerializer(unmodColl2,
UnmodifiableCollectionsSerializer.class);
I dont know if is a real problem, but i think it's necessary to review.
Thanks :)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
