RE: Using state processor API to read state defined with a TypeHint

Message- From: Roman Khachatryan Sent: Freitag, 8. April 2022 11:48 To: Alexis Sarda-Espinosa Cc: user@flink.apache.org Subject: Re: Using state processor API to read state defined with a TypeHint Hi Alexis, I think your setup is fine, but probably Java type erasure makes Flink consider

Re: Using state processor API to read state defined with a TypeHint

Hi Alexis, I think your setup is fine, but probably Java type erasure makes Flink consider the two serializers as different. Could you try creating a MapStateDescriptor by explicitly providing serializers (constructed manually)? Regards, Roman On Fri, Apr 8, 2022 at 10:01 AM Alexis

Using state processor API to read state defined with a TypeHint

Hi everyone, I have a ProcessWindowFunction that uses Global window state. It uses MapState with a descriptor defined like this: MapStateDescriptor> msd = new MapStateDescriptor<>( "descriptorName", TypeInformation.of(Long.class), TypeInformation.of(new TypeHint>() {})