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