ginal 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 con
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 Sarda-Espino
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>() {})
);