所以我想在我的水印落后时发出警报。
我想使用 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
转换