开发者社区> 问答> 正文

flink作业通过grafana监控,若想发出报警该如何选择指标的问题

Hi,请教大家一个问题:

目前使用grafana监控flink的作业,想实现一个任务挂掉就报警的功能,初步想法是:监控checkpoint size的指标,一旦这个指标为0,就认为任务挂掉,但实际操作后,发现了两个问题:

① 如果kill掉任务,grafana上的flink所有指标都会一直保持最后接收到的值不变; ② 如果cancel掉任务,grafana上的flink所有指标都会突然中断;

所以,我上面说的想法永远都不会出发告警,因为这个checkpoint size的指标在任务挂掉也不会归为0值;

我又尝试了用一分钟前的job_uptime减去一分钟后的job_uptime,但是这样报警并不优雅,在任务刚启动时会有误报,因为任务刚启动时,一分钟前是没有数据的。

所以现在很疑惑,请教一下大家如果用grafana监控flink作业的,该选用什么样的指标和用什么规则,可以优雅的报警呢?*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-08 12:14:06 1673 0
1 条回答
写回答
取消 提交回答
  • 对的是我!

    我们当前的实现是,每分钟调用yarn的rest api 获取作业状态,和实时计算平台上的作业状态对比,如果挂掉就电话报警,同时平台上作业状态修改为运行异常。 *来自志愿者整理的flink邮件归档

    2021-12-08 17:04:35
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载

相关镜像