|
|
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
Thanks,
|
Locked
