Hello,

I am looking at the new APIs for state processing [1] and I see custom
serde should be supported with a property like
"fields.#.value-type-factory". However, I'm not sure if that applies to
MapState. I have an operator with MapState using String as key but with a
custom type serializer for the values [2], and regardless of how I
define my value type factory, I get an exception stating that the new
serializer must be compatible with the old one, where both the old and new
serializers just mention its the map serializer.

Am I missing something or is this actually not supported yet?

[1]
https://nightlies.apache.org/flink/flink-docs-release-2.1/docs/libs/state_processor_api/#table-api
[2] https://gist.github.com/asardaes/714b8c1db0c4020f5fde9865b95fc398

Regards,
Alexis.

Reply via email to