Re: [External] : Re: How to define TypeInformation for Flink recursive resolved POJO

2022-05-12 Thread Fuyao Li
abled in the ExecutionConfig and type java.util.Set is treated as a generic type. Thanks, Fuyao From: Weihua Hu Date: Thursday, May 12, 2022 at 07:24 To: Fuyao Li Cc: user Subject: [External] : Re: How to define TypeInformation for Flink recursive resolved POJO Hi, Fuyao How did you defi

Re: [External] : Re: How to define TypeInformation for Flink recursive resolved POJO

2022-05-12 Thread Fuyao Li
TypeInformation.of(new TypeHint>() {}); } } But I still get the following errors. Generic types have been disabled in the ExecutionConfig and type java.util.Set is treated as a generic type. Thanks, Fuyao From: Weihua Hu Date: Thursday, May 12, 2022 at 07:24 To: Fuyao Li Cc: user Su

Re: How to define TypeInformation for Flink recursive resolved POJO

2022-05-12 Thread Weihua Hu
Hi, Fuyao How did you define these classes? There is some requirements for POJO as flink docs[1] said: The class must be public. It must have a public constructor without arguments (default constructor). All fields are either public or must be accessible through getter and setter functions. F

How to define TypeInformation for Flink recursive resolved POJO

2022-05-11 Thread Fuyao Li
Hi Community, I have a POJO that has nested recursively resolved structure. How should I define the @TypeInfo annotation correctly to avoid stack overflow exception when starting the application. Basically, Class Metadata Map fields Class FieldDefinition Metadata parentMetadata The Metadata c