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