使用 PromQL 的 Flink Watermark 延迟答案

【问题标题】：Flink Watermark latency with PromQL使用 PromQL 的 Flink Watermark 延迟
【发布时间】：2020-05-11 17:48:01
【问题描述】：

所以我想在我的水印落后时发出警报。

我想使用 flink 的 job manager 报告的指标。像这样的东西，但这并不像我喜欢的那样工作。

(timestamp(flink_taskmanager_job_task_operator_currentInputWatermark{task_name=~"my_window.*"})-(4*60*60*1000))-flink_taskmanager_job_task_operator_currentInputWatermark{task_name=~"my_window.*"}

口头上：我想获得 currentTime 的差异（报告指标的时间） - wmatermark ts。

(4*60*60*1000) 是转换为 EDT -- 有没有更好的方法来做到这一点？

【问题讨论】：

标签： apache-flink prometheus prometheus-alertmanager promql

【解决方案1】：

好的。所以上面的查询几乎是完美的。我做错了将已经 EDT 时间戳转移到-4h。以下是执行此操作的完美查询：

timestamp(flink_taskmanager_job_task_operator_currentInputWatermark{task_name="my_window",job_name="session"})*1000-flink_taskmanager_job_task_operator_currentInputWatermark{task_name="my_window",job_name="session"}

flink_taskmanager_job_task_operator_currentInputWatermark 报告不会以毫秒为单位报告，但timestamp 确实如此，因此*1000 转换

【讨论】：