gpt4 book ai didi

java - Flink 运行时如何获取任务管理器 JVM 指标(例如 'Status.JVM.Memory.Heap.Used' )?

转载 作者:行者123 更新时间:2023-12-02 09:06:40 27 4
gpt4 key购买 nike

有几篇博客文章介绍了 Flink 指标报告系统的高层设计。但是,我仍然不清楚 JVM 相关指标(例如“Status.JVM.Memory.Heap.Used”)是如何收集的。

我试图在 Flink 源代码中找到这一点。 MemoryLogger.java 似乎在获取 JVM 相关指标方面做了一些工作。 https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/MemoryLogger.java#L88 。但是,目前尚不清楚指标如何流回 MetricsRegistry。对此的任何指示将不胜感激。

最佳答案

Flink 有一个专用线程来收集每个任务管理器的系统相关指标。

系统指标由 SystemResourcesCounter 收集

可以通过ManagementFactory.getMemoryMXBean().getHeapMemoryUsage()访问JVM内存指标

获取 JVM 相关指标的代码位于 MetricUtils.javaflink-runtime模块中。

关于java - Flink 运行时如何获取任务管理器 JVM 指标(例如 'Status.JVM.Memory.Heap.Used' )?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59765677/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com