Hello Flink dev and user,

We have a pipeline that read both bounded and unbounded sources and our
understanding is that when the bounded sources complete they should get a
watermark of +inf and then we should be able to take a savepoint and safely
restart the pipeline. However, we have source that never get watermarks and
we are confused as to what we are seeing and what we should expect

[image: Screen Shot 2020-01-08 at 3.23.42 PM.png]

Thanks,
Cam

Reply via email to