基础指标：Flink指标
介绍通过Flink服务上报到AOM的指标的类别、名称、含义等信息。
分类 | 指标 | 指标含义 | 单位 |
|---|---|---|---|
CPU | flink_jobmanager_Status_JVM_CPU_Load | JobManager中JVM的CPU负载。 | 无 |
flink_jobmanager_Status_JVM_CPU_Time | jobmanager中JVM使用的CPU时间。 | 无 | |
flink_jobmanager_Status_ProcessTree_CPU_Usage | JobManager 中JVM的CPU使用率。 | 无 | |
flink_taskmanager_Status_JVM_CPU_Load | TaskManager 中JVM的CPU负载。 | 无 | |
flink_taskmanager_Status_JVM_CPU_Time | TaskManager中JVM使用的CPU时间。 | 无 | |
flink_taskmanager_Status_ProcessTree_CPU_Usage | TaskManager 中的JVM的CPU使用率。 | 无 | |
Memory | flink_jobmanager_Status_JVM_Memory_Heap_Used | JobManager的堆内存使用量。 | 字节（Byte） |
flink_jobmanager_Status_JVM_Memory_Heap_Committed | 保证JobManager的JVM可用的堆内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Heap_Max | JobManager中可用于内存管理的最大堆内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_NonHeap_Used | JobManager的堆外内存使用量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_NonHeap_Committed | 保证JobManager的JVM可用的堆外内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_NonHeap_Max | JobManager中可用于内存管理的最大堆外内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Metaspace_Used | JobManager MetaSpace内存池中当前使用的内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Metaspace_Committed | JobManager MetaSpace内存池中保证可供JVM使用的内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Metaspace_Max | JobManager MetaSpace内存池中可以使用的最大内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Direct_Count | JobManager direct缓冲池中的缓冲区数。 | 无 | |
flink_jobmanager_Status_JVM_Memory_Direct_MemoryUsed | JobManager中JVM用于direct缓冲池的内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Direct_TotalCapacity | JobManager中direct缓冲池中所有缓冲区的总容量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Mapped_Count | JobManager中mapped缓冲池中的缓冲区个数。 | 无 | |
flink_jobmanager_Status_JVM_Memory_Mapped_MemoryUsed | JobManager中JVM用于mapped缓冲池的内存量。 | 字节（Byte） | |
flink_jobmanager_Status_JVM_Memory_Mapped_TotalCapacity | JobManager中mapped缓冲池中所有缓冲区的总容量 | 字节（Byte） | |
flink_jobmanager_Status_Flink_Memory_Managed_Used | JobManager中已使用的托管内存量。 | 字节（Byte） | |
flink_jobmanager_Status_Flink_Memory_Managed_Total | JobManager中托管内存总量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Heap_Used | TaskManager的堆内存使用量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Heap_Committed | 保证TaskManager的JVM可用的堆内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Heap_Max | TaskManager中可用于内存管理的最大堆内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_NonHeap_Used | TaskManager的堆外内存使用量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_NonHeap_Committed | 保证TaskManager的JVM可用的堆外内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_NonHeap_Max | TaskManager中可用于内存管理的最大堆外内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Metaspace_Used | TaskManager MetaSpace内存池中当前使用的内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Metaspace_Committed | TaskManager MetaSpace内存池中保证可供JVM使用的内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Metaspace_Max | TaskManager MetaSpace内存池中可以使用的最大内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Direct_Count | TaskManager direct缓冲池中的缓冲区数。 | 无 | |
flink_taskmanager_Status_JVM_Memory_Direct_MemoryUsed | TaskManager中JVM用于direct缓冲池的内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Direct_TotalCapacity | TaskManager中direct缓冲池中所有缓冲区的总容量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Mapped_Count | TaskManager中mapped缓冲池中的缓冲区个数。 | 无 | |
flink_taskmanager_Status_JVM_Memory_Mapped_MemoryUsed | TaskManager中JVM用于mapped缓冲池的内存量。 | 字节（Byte） | |
flink_taskmanager_Status_JVM_Memory_Mapped_TotalCapacity | TaskManager中mapped缓冲池中所有缓冲区的总容量。 | 字节（Byte） | |
flink_taskmanager_Status_Flink_Memory_Managed_Used | TaskManager中已使用的托管内存量。 | 字节（Byte） | |
flink_taskmanager_Status_Flink_Memory_Managed_Total | TaskManager中托管内存总量。 | 字节（Byte） | |
flink_taskmanager_Status_ProcessTree_Memory_RSS | 通过Linux获取整个进程的内存。 | 字节（Byte） | |
Threads | flink_jobmanager_Status_JVM_Threads_Count | JobManager中活动的线程总数。 | 个 |
flink_taskmanager_Status_JVM_Threads_Count | TaskManager中活动中的线程总数。 | 个 | |
GarbageCollection | flink_jobmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Count | JobManager CMS垃圾回收器的回收次数。 | 次数 |
flink_jobmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Time | JobManager CMS执行垃圾回收总耗时。 | 毫秒（ms） | |
flink_jobmanager_Status_JVM_GarbageCollector_ParNew_Count | JobManager GC次数。 | 次数 | |
flink_jobmanager_Status_JVM_GarbageCollector_ParNew_Time | JobManager每次GC时间。 | 毫秒（ms） | |
flink_taskmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Count | TaskManager CMS垃圾回收器的回收次数。 | 次数 | |
flink_taskmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Time | TaskManager CMS执行垃圾回收总耗时。 | 毫秒（ms） | |
flink_taskmanager_Status_JVM_GarbageCollector_ParNew_Count | TaskManager GC次数。 | 次数 | |
flink_taskmanager_Status_JVM_GarbageCollector_ParNew_Time | TaskManager每次GC时间。 | 毫秒（ms） | |
ClassLoader | flink_jobmanager_Status_JVM_ClassLoader_ClassesLoaded | JobManager自JVM启动以来加载的类的总数。 | 无 |
flink_jobmanager_Status_JVM_ClassLoader_ClassesUnloaded | JobManager自JVM启动以来卸载的类的总数。 | 无 | |
flink_taskmanager_Status_JVM_ClassLoader_ClassesLoaded | TaskManager自JVM启动以来加载的类的总数。 | 无 | |
flink_taskmanager_Status_JVM_ClassLoader_ClassesUnloaded | TaskManager自JVM启动以来卸载的类的总数。 | 无 | |
Network | flink_taskmanager_Status_Network_AvailableMemorySegments | TaskManager未使用的内存segments的个数。 | 无 |
flink_taskmanager_Status_Network_TotalMemorySegments | TaskManager中分配的内存segments的总数。 | 无 | |
Default shuffle service | flink_taskmanager_Status_Shuffle_Netty_AvailableMemorySegments | TaskManager未使用的内存segments的个数。 | 无 |
flink_taskmanager_Status_Shuffle_Netty_UsedMemorySegments | TaskManager已使用的内存segments的个数。 | 无 | |
flink_taskmanager_Status_Shuffle_Netty_TotalMemorySegments | TaskManager分配的内存segments的个数。 | 无 | |
flink_taskmanager_Status_Shuffle_Netty_AvailableMemory | TaskManager中未使用的内存量。 | 字节（Byte） | |
flink_taskmanager_Status_Shuffle_Netty_UsedMemory | TaskManager中已使用的内存量。 | 字节（Byte） | |
flink_taskmanager_Status_Shuffle_Netty_TotalMemory | TaskManager中分配的内存量。 | 字节（Byte） | |
Availability | flink_jobmanager_job_numRestarts | 自作业提交以来的重新启动总数。 | 次 |
Checkpointing | flink_jobmanager_job_lastCheckpointDuration | 完成最新checkpoint所用的时间 | 毫秒（ms） |
flink_jobmanager_job_lastCheckpointSize | 最新checkpoint的大小，如果启用了增量检查点或更改日志，则此度量可能与lastCheckpointFullSize不同。 | 字节（Byte） | |
flink_jobmanager_job_numberOfInProgressCheckpoints | 正在进行的checkpoint的数量。 | 个 | |
flink_jobmanager_job_numberOfCompletedCheckpoints | 成功完成的checkpoint的数量。 | 个 | |
flink_jobmanager_job_numberOfFailedCheckpoints | 失败的checkpoint的数量。 | 个 | |
flink_jobmanager_job_totalNumberOfCheckpoints | 所有checkpoint的总数。 | 个 | |
IO | flink_taskmanager_job_task_numBytesOut | Task输出的字节总数。 | 字节（Byte） |
flink_taskmanager_job_task_numBytesOutPerSecond | Task每秒输出的字节总数。 | 字节/秒（Byte/s） | |
flink_taskmanager_job_task_isBackPressured | Task是否反压。 | 无 | |
flink_taskmanager_job_task_numRecordsIn | Task收到的记录总数。 | 条 | |
flink_taskmanager_job_task_numRecordsInPerSecond | Task每秒收到的记录总数。 | 条/秒 | |
flink_taskmanager_job_task_numBytesIn | Task收到的字节数。 | 字节（Byte） | |
flink_taskmanager_job_task_numBytesInPerSecond | Task每秒收到的字节数。 | 字节/秒（Byte/s） | |
flink_taskmanager_job_task_numRecordsOut | Task发出的记录总数。 | 条 | |
flink_taskmanager_job_task_numRecordsOutPerSecond | Task每秒发出的记录总数。 | 条/秒 | |
flink_taskmanager_job_task_operator_numRecordsIn | Operator收到的记录总数。 | 条 | |
flink_taskmanager_job_task_operator_numRecordsInPerSecond | Operator每秒收到的记录总数。 | 条/秒 | |
flink_taskmanager_job_task_operator_numRecordsOut | Operator发出的记录总数。 | 条 | |
flink_taskmanager_job_task_operator_numRecordsOutPerSecond | Operator每秒发出的记录总数。 | 条/秒 | |
flink_taskmanager_job_task_operator_source_numRecordsIn | source收到的记录总数。 | 条 | |
flink_taskmanager_job_task_operator_sink_numRecordsOut | Sink端输出记录总数。 | 条 | |
flink_taskmanager_job_task_operator_source_numRecordsInPerSecond | 数据源Source端每秒输入的记录数。 | 条/秒 | |
flink_taskmanager_job_task_operator_sink_numRecordsOutPerSecond | 数据目的Sink端每秒输出的记录数。 | 条/秒 | |
kafka connector | flink_taskmanager_job_task_operator_currentEmitEventTimeLag | 数据的事件时间与数据离开 Source 时的间隔 | 毫秒（ms） |
flink_taskmanager_job_task_operator_currentFetchEventTimeLag | 数据的事件时间与数据进入Source的时间间隔 | 毫秒（ms） | |
flink_taskmanager_job_task_operator_sourceIdleTime | Source 闲置时长。 | 毫秒（ms） | |
flink_taskmanager_job_task_operator_pendingRecords | 尚未被 Source 拉取的数据数量 | 条 |
