Re: Watermarks

[Perez]

Hi Liu and Jinfeng,

I am trying to implement KafkaDeserializationSchema for Pyflink but am
unable to get any examples. Can you share some links or references using
which I can understand and try to implement myself?

Perez sid.