flink水印延迟与promql

92vpleto 于 2021-06-26 发布在 Flink

关注(0)|答案(1)|浏览(503)

所以我想在我的水印落后时发出警报。
我想使用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有更好的方法吗？

apache-flink prometheus prometheus-alertmanager promql

来源：https://stackoverflow.com/questions/61735954/flink-watermark-latency-with-promql

1条答案

按热度按时间

p8ekf7hl1#

好啊。所以上面的查询几乎是完美的。我做错的是把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 转换

赞(0）回复(0）举报 2021-06-26

我来回答

flink水印延迟与promql

1条答案

相关问题

热门标签

最新问答