想监控 flink的job中的所有状态内容以及有效期情况,有啥办法呢么?[阿里云实时计算 Flink版]

想监控 flink的job中的所有状态内容以及有效期情况,有啥办法呢么?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 可以在Flink Web UI中查看Job的状态,查看Job的运行时间,查看Job的checkpoint状态,以及查看Job的有效期情况。 还可以使用Flink的命令行工具,如flink list checkpoints,来查看当前存在的checkpoint,以及查看checkpoint的有效期情况。

  2. Flink Metric内置的监控涵盖面丰富,支持: 1. 系统级别的监控:CPU状态信息、内存状态信息等(默认关闭,需要更改配置文件打开,且lib目录下需要添加相关依赖jar包) 2. JVM级别的监控:CPU占用率、堆内存使用情况、线程数量、GC已经类加载数量。 3. Flink job/Task/Operator级别的监控:checkPoint相关(耗时、大小、数量)、算子吞吐量、水位线。内置Connector监控,若使用FlinkKafkaConsumer,可以监控job消费kafka速度、offset的LAG值。这一级别的监控也支持自定义。