It's a known issue that various connectors/wrappers/etc did not respect
the schema lifecycle.
This was fixed in 1.16.0 in
https://issues.apache.org/jira/browse/FLINK-28807.
You will have to lazily initialize the mapper in the serialize() method
for previous versions.
On 24/01/2023 11:52, P
Hi Flink-User!
I recently updated a Flink job from Flink version 1.13 to 1.15 (managed by
AWS). The Flink Job is written in Java.
I found out that the Kinesis Producer was deprecated in favour of Kinesis
Streams Sink [1]. When upgrading to the new sink I stumbled upon a problem
withe a custom
