Re: Watermark through Rest Api

2018-10-08 Thread Piotr Nowojski
Hi, Watermarks are tracked per Task/Operator level: https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#io Tracking watermarks on the job level would be problematic, since it would r

Watermark through Rest Api

2018-10-08 Thread Gregory Fee
Hello! I am interested in getting the current low watermark for tasks in my Flink jobs. I know how to see them in the UI. I'm interested in getting them programmatically, hopefully via rest api. The documentation says that they are exposed as metrics but I don't see watermark info in the 'metrics'