PromQL 的 Flink Watermark 延迟

Question

所以我想在我的水印落后时提醒。

我想使用 flink 的作业管理器报告的指标。类似这样的东西，但我不喜欢这样。

(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 -- 有更好的方法吗？

Answer 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 转换