Hi Juan,
can you elaborate a bit on why you want to put the WatermarkAssigner itself
into state? It is generally unusual to store a UDF in Managed State.
Cheers,
Konstantin
On Fri, Jul 5, 2019 at 5:07 PM Juan Gentile wrote:
> Hello,
>
>
>
> We are currently facing an issue where we need to
Hello,
We are currently facing an issue where we need to store the instance of the
watermark and timestamp assigner in the state while consumer from Kafka.
For that purpose we took a look at FlinkKafkaConsumerBase and noticed that
since the methods (snapshotState and initializeState from the
Ch
