Hi Sachin,
Check the last few comments I wrote in this thread:
https://lists.apache.org/thread/l71d1cqo9xv8rsw0gfjo19kb1pct2xj1
Regards,
Alexis.
On Wed, 20 Mar 2024, 18:51 Sachin Mittal, wrote:
> Hi,
> I saw the post but I did not understand how I would configure these fields
> to use those
Hi,
I saw the post but I did not understand how I would configure these fields
to use those serializers. (I can change the set type to a list type for
now).
As per the docs I see that we can annotate fields with @TypeInfo
But what I did not get is how using this annotation I can use
Flink doesn’t have built-in support for serializing Sets.
See this (stale) issue about the same:
https://issues.apache.org/jira/browse/FLINK-16729
You could create a custom serializer for sets, see
Hi,
I have a Pojo class like this
public class A {
public String str;
public Set aSet;
public Map dMap;
}
However when I start the flink program I get this message:
org.apache.flink.api.java.typeutils.TypeExtractor[] - Field A#
dMap will be processed as GenericType. Please read
