Hi,
I have a proto which has a map field in it. When i try to use it in Flink
using Kyro serializer, im getting following error when pushing the output
to Kafka
Caused by: java.lang.UnsupportedOperationException
at java.util.Collections$UnmodifiableCollection.add(Collections.java:1057)
at
com.eso
Are you registering the protobuf serializer with Kryo? (See
https://flink.apache.org/news/2020/04/15/flink-serialization-tuning-vol-1.html#protobuf-via-kryo)
From: Sudan S
Date: Monday, October 26, 2020 at 11:44 AM
To: User-Flink
Subject: Getting UnsupportedException in Kyro for proto maps
Hi
