I wonder if stream source task which extract timestamps and watermark from
source element fail and restart with fault tolerance, what kind of
watermark it would emit?

Reply via email to