使用 PromQL 的 Flink 水印延迟



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

我想使用 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.*"}

口头上:我想在当前时间(报告指标的时间(中获得差异 - wmatermark ts。

(4*60*60*1000)是转换为EDT - 有更好的方法吗?

好的。所以上面的查询几乎是完美的。 我做错了将已经 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报告不以MS为单位报告,但timestamp报告因此*1000转换

相关内容

  • 没有找到相关文章

最新更新