# Flink端点资源和作业指标 #### 资源指标 表1FlinkJob端点资源指标 | 指标ID | 指标名称 | 指标含义 | 取值范围 | 单位 | 进制 | 维度 | 监控周期 | |:---|:---|:---|:---|:---|:---|:---|:---| | aidatalake_endpoint_flink_used_cpu_num | CPU使用量 | 当前端点已使用的CPU量。 | ≥0 | vCPU | 不涉及 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_max_cpu_num | CPU配额总量 | 当前端点可分配的CPU最大限制。 | ≥0 | vCPU | 不涉及 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_cpu_rate | CPU使用率 | 当前端点CPU资源的使用率平均值。 | 0\~100 | 百分比（%） | 不涉及 | workspace_id,endpoint_id,endpoint_type | 1分钟 | | aidatalake_endpoint_flink_used_memory_num | 内存使用量 | 当前端点已使用的内存量。 | ≥0 | Byte | 1024 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_max_memory_num | 内存配额总量 | 当前端点可分配的内存最大容量。 | ≥0 | Byte | 1024 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_memory_rate | 内存使用率 | 当前端点内存资源的使用率平均值。 | 0\~100 | 百分比（%） | 不涉及 | workspace_id,endpoint_id,endpoint_type | 1分钟 | #### Flink作业统计指标 表2FlinkJob端点作业指标 | 指标ID | 指标名称 | 指标含义 | 取值范围 | 单位 | 进制 | 维度 | 监控周期 | |:---|:---|:---|:---|:---|:---|:---|:---| | aidatalake_endpoint_flink_submitting_jobs_count | 提交中作业数 | 当前端点正在提交状态的作业数统计，并计算出作业数的最大值、最小值和平均值。 | ≥0 | Count | 不涉及 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_running_jobs_count | 运行中作业数 | 当前端点正在运行中的作业数统计，并计算出作业数的最大值、最小值和平均值。 | ≥0 | Count | 不涉及 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_completed_jobs_count | 成功作业数 | 当前端点成功的作业数统计，并计算出作业数的最大值、最小值和平均值。 | ≥0 | Count | 不涉及 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_failed_jobs_count | 失败作业数 | 当前端点失败的作业数统计，并计算出作业数的最大值、最小值和平均值。 | ≥0 | Count | 不涉及 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_cancelled_jobs_count | 已取消作业数 | 当前端点已取消运行的作业数统计，并计算出作业数的最大值、最小值和平均值。FlinkJob端点：包含已取消。 | ≥0 | Count | 不涉及 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_max_submitting_duration_ms | 作业提交最大时长 | 当前端点该时间点提交中的作业最长的持续时间。FlinkJob端点：包含排队中、启动中。 | ≥0 | ms | 1000 | workspace_id,endpoint_id | 1分钟 | | aidatalake_endpoint_flink_max_running_duration_ms | 作业运行最大时长 | 当前端点该时间点运行中的作业最长的持续时间。FlinkJob端点：包含运行中。 | ≥0 | ms | 1000 | workspace_id,endpoint_id | 1分钟 | #### Flink作业指标 表3Flink作业指标 | **指标** | **含义** | **取值范围** | **单位** | **进制** | **维度** | |:---|:---|:---|:---|:---|:---| | flink_jobmanager_Status_JVM_CPU_Load | JobManager中JVM的CPU负载。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_CPU_Time | jobmanager中JVM使用的CPU时间。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_ClassLoader_ClassesLoaded | JobManager自JVM启动以来加载的类的总数。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_ClassLoader_ClassesUnloaded | JobManager自JVM启动以来卸载的类的总数。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Direct_Count | JobManager direct缓冲池中的缓冲区数。 | ≥0 | 无 | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Direct_MemoryUsed | JobManager中JVM用于direct缓冲池的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Direct_TotalCapacity | JobManager中direct缓冲池中所有缓冲区的总容量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Heap_Committed | 保证JobManager的JVM可用的堆内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Heap_Max | JobManager中可用于内存管理的最大堆内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Heap_Used | JobManager的堆内存使用量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Mapped_Count | JobManager中mapped缓冲池中的缓冲区个数。 | ≥0 | 无 | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Mapped_MemoryUsed | JobManager中JVM用于mapped缓冲池的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Mapped_TotalCapacity | JobManager中mapped缓冲池中所有缓冲区的总容量 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Metaspace_Committed | JobManager MetaSpace内存池中保证可供JVM使用的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Metaspace_Max | JobManager MetaSpace内存池中可以使用的最大内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_Metaspace_Used | JobManager MetaSpace内存池中当前使用的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_NonHeap_Committed | 保证JobManager的JVM可用的堆外内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_NonHeap_Max | JobManager中可用于内存管理的最大堆外内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Memory_NonHeap_Used | JobManager的堆外内存使用量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_Threads_Count | JobManager中活动的线程总数。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCheckpointDuration | 完成最新checkpoint所用的时间 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCheckpointSize | 最新checkpoint的大小，如果启用了增量检查点或更改日志，则此度量可能与lastCheckpointFullSize不同。 | ≥0 | 字节（Byte） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_numRestarts | 自作业提交以来的重新启动总数。 | ≥0 | 次 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_numberOfCompletedCheckpoints | 成功完成的checkpoint的数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_numberOfFailedCheckpoints | 失败的checkpoint的数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_numberOfInProgressCheckpoints | 正在进行的checkpoint的数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_totalNumberOfCheckpoints | 所有checkpoint的总数。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_Flink_Memory_Managed_Total | TaskManager中托管内存总量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_Flink_Memory_Managed_Used | TaskManager中已使用的托管内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_CPU_Load | TaskManager 中JVM的CPU负载。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_CPU_Time | TaskManager中JVM使用的CPU时间。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_ClassLoader_ClassesLoaded | TaskManager自JVM启动以来加载的类的总数。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_ClassLoader_ClassesUnloaded | TaskManager自JVM启动以来卸载的类的总数。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Direct_Count | TaskManager direct缓冲池中的缓冲区数。 | ≥0 | 无 | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Direct_MemoryUsed | TaskManager中JVM用于direct缓冲池的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Direct_TotalCapacity | TaskManager中direct缓冲池中所有缓冲区的总容量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Heap_Committed | 保证TaskManager的JVM可用的堆内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Heap_Max | TaskManager中可用于内存管理的最大堆内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Heap_Used | TaskManager的堆内存使用量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Mapped_Count | TaskManager中mapped缓冲池中的缓冲区个数。 | ≥0 | 无 | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Mapped_MemoryUsed | TaskManager中JVM用于mapped缓冲池的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Mapped_TotalCapacity | TaskManager中mapped缓冲池中所有缓冲区的总容量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Metaspace_Committed | TaskManager MetaSpace内存池中保证可供JVM使用的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Metaspace_Max | TaskManager MetaSpace内存池中可以使用的最大内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_Metaspace_Used | TaskManager MetaSpace内存池中当前使用的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_NonHeap_Committed | 保证TaskManager的JVM可用的堆外内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_NonHeap_Max | TaskManager中可用于内存管理的最大堆外内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Memory_NonHeap_Used | TaskManager的堆外内存使用量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_Threads_Count | TaskManager中活动中的线程总数。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_Network_AvailableMemorySegments | TaskManager未使用的内存segments的个数。 | ≥0 | 无 | 10 | job_id, endpoint_id | | flink_taskmanager_Status_Network_TotalMemorySegments | TaskManager中分配的内存segments的总数。 | ≥0 | 无 | 10 | job_id, endpoint_id | | flink_taskmanager_Status_Shuffle_Netty_AvailableMemory | TaskManager中未使用的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_Shuffle_Netty_AvailableMemorySegments | TaskManager未使用的内存segments的个数。 | ≥0 | 无 | 10 | job_id, endpoint_id | | flink_taskmanager_Status_Shuffle_Netty_TotalMemory | TaskManager中分配的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_Shuffle_Netty_TotalMemorySegments | TaskManager分配的内存segments的个数。 | ≥0 | 无 | 10 | job_id, endpoint_id | | flink_taskmanager_Status_Shuffle_Netty_UsedMemory | TaskManager中已使用的内存量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_Status_Shuffle_Netty_UsedMemorySegments | TaskManager已使用的内存segments的个数。 | ≥0 | 无 | 10 | job_id, endpoint_id | | flink_taskmanager_job_task_isBackPressured | Task是否反压。 | 0或1 | 无 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesIn | Task收到的字节数。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesInPerSecond | Task每秒收到的字节数。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesOut | Task输出的字节总数。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesOutPerSecond | Task每秒输出的字节总数。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numRecordsIn | Task收到的记录总数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numRecordsInPerSecond | Task每秒收到的记录总数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_numRecordsOut | Task发出的记录总数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numRecordsOutPerSecond | Task每秒发出的记录总数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numRecordsIn | Operator收到的记录总数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numRecordsInPerSecond | Operator每秒收到的记录总数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numRecordsOut | Operator发出的记录总数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numRecordsOutPerSecond | Operator每秒发出的记录总数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_sink_numRecordsOut | Sink端输出记录总数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_sink_numRecordsOutPerSecond | 数据目的Sink端每秒输出的记录数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_source_numRecordsIn | source收到的记录总数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_source_numRecordsInPerSecond | 数据源Source端每秒输入的记录数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_All_Count | JobManager所有垃圾收集器执行的累计次数。 | ≥0 | 次数 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_All_Time | JobManager所有垃圾收集器累计耗时。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_All_TimeMsPerSecond | JobManager每秒用于GC的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_Copy_Count | JobManager Copy垃圾收集器累计执行次数。 | ≥0 | 次数 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_Copy_Time | JobManager Copy垃圾收集器累计耗时。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_Copy_TimeMsPerSecond | JobManager每秒用于Copy GC 的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_MarkSweepCompact_Count | JobManager Mark-Sweep-Compact垃圾收集器累计执行次数。 | ≥0 | 次数 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_MarkSweepCompact_Time | JobManager Mark-Sweep-Compact垃圾收集器累计耗时。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_Status_JVM_GarbageCollector_MarkSweepCompact_TimeMsPerSecond | JobManager每秒用于Mark-Sweep-Compact GC的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_jobmanager_job_cancellingTime | 作业处于CANCELLING状态的累计时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_createdTime | 作业处于CREATED状态的时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_deployingTime | 作业处于DEPLOYING状态的时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_downtime | 作业处于不可运行状态的累计时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_failingTime | 作业处于FAILING状态的累计时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_fullRestarts | 作业发生完全重启的次数。 | ≥0 | 次 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_initializingTime | 作业处于INITIALIZING状态的时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCheckpointExternalPath | 最近一次Checkpoint的外部存储路径（文本指标，Prometheus 端导出占位值 0）。 | ≥0 | 无（文本） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCheckpointFullSize | 最近一次Checkpoint的完整大小。 | ≥0 | 字节（Byte） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCheckpointPersistedData | 最近一次Checkpoint实际持久化到远端存储的数据量。 | ≥0 | 字节（Byte） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCheckpointProcessedData | 最近一次Checkpoint 处理的数据量。 | ≥0 | 字节（Byte） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCheckpointRestoreTimestamp | 最近一次 Checkpoint 在协调器上恢复时的时间戳。 | ≥0 | 毫秒（ms，时间戳） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_lastCompletedCheckpointId | 最近一次成功完成的Checkpoint ID。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_restartingTime | 作业处于RESTARTING状态的累计时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_runningTime | 作业处于RUNNING状态的累计时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_job_uptime | 作业自最近一次启动以来的连续运行时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_jobmanager_numPendingTaskManagers | 等待注册的TaskManager数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_numRegisteredTaskManagers | 当前已注册到JobManager的 TaskManager 数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_numRunningJobs | 当前正在运行的作业数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_startWorkFailurePerSecond | 每秒启动工作失败的次数。 | ≥0 | 次/秒 | 1000 | job_id, endpoint_id | | flink_jobmanager_taskSlotsAvailable | 当前可用的Task Slot数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_jobmanager_taskSlotsTotal | Task Slot总数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_All_Count | TaskManager 所有垃圾收集器执行的累计次数。 | ≥0 | 次数 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_All_Time | TaskManager所有垃圾收集器累计耗时。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_All_TimeMsPerSecond | TaskManager每秒用于GC的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_Copy_Count | TaskManager Copy垃圾收集器累计执行次数。 | ≥0 | 次数 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_Copy_Time | TaskManager Copy垃圾收集器累计耗时。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_Copy_TimeMsPerSecond | TaskManager每秒用于Copy GC 的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_MarkSweepCompact_Count | TaskManager Mark-Sweep-Compact垃圾收集器累计执行次数。 | ≥0 | 次数 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_MarkSweepCompact_Time | TaskManager Mark-Sweep-Compact垃圾收集器累计耗时。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_Status_JVM_GarbageCollector_MarkSweepCompact_TimeMsPerSecond | TaskManager每秒用于Mark-Sweep-Compact GC的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_Status_Shuffle_Netty_RequestedMemoryUsage | Netty Shuffle内存池请求内存的使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_Buffers_inPoolUsage | 输入Buffer池使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_Buffers_inputExclusiveBuffersUsage | 输入侧独占Buffer使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_Buffers_inputFloatingBuffersUsage | 输入侧共享（Floating）Buffer 使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_Buffers_inputQueueLength | 输入通道数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_Buffers_inputQueueSize | 输入队列中当前积压的Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBuffersInLocal | Task从同一TaskManager内的其他Task接收的网络Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBuffersInLocalPerSecond | Task每秒从同一TaskManager内的其他Task接收的网络Buffer数量。 | ≥0 | 个/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBuffersInRemote | Task从其他TaskManager接收的网络Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBuffersInRemotePerSecond | Task每秒从其他TaskManager接收的网络Buffer数量。 | ≥0 | 个/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBytesInLocal | Task从同一TaskManager内的其他Task接收的累计数据量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBytesInLocalPerSecond | Task每秒从同一TaskManager内的其他Task接收的数据量。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBytesInRemote | Task从其他TaskManager接收的累计数据量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Input_numBytesInRemotePerSecond | Task每秒从其他TaskManager 接收的数据量。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Output_Buffers_outPoolUsage | 输出Buffer池使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Output_Buffers_outputQueueLength | 输出通道数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_Shuffle_Netty_Output_Buffers_outputQueueSize | 输出队列中当前积压的Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_accumulateBackPressuredTimeMs | Task自启动以来累计处于反压状态的时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_accumulateBusyTimeMs | Task自启动以来累计处于忙碌状态的时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_accumulateIdleTimeMs | Task自启动以来累计处于空闲状态的时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_backPressuredTimeMsPerSecond | 每秒Task处于反压状态的时间，包括软反压和硬反压。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_inPoolUsage | 输入Buffer池使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_inputExclusiveBuffersUsage | 输入侧独占Buffer使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_inputFloatingBuffersUsage | 输入侧共享（Floating）Buffer 使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_inputQueueLength | 输入通道数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_inputQueueSize | 输入队列中当前积压的Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_outPoolUsage | 输出Buffer池使用率。 | 0\~100 | % | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_outputQueueLength | 输出通道数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_buffers_outputQueueSize | 输出队列中当前积压的Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_busyTimeMsPerSecond | 每秒Task处于忙碌状态的时间，即既非空闲也未处于反压状态的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_changelogBusyTimeMsPerSecond | 启用Changelog State Backend 时，每秒用于处理Changelog状态相关工作的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_checkpointAlignmentTime | 该Task等待所有输入通道的 Checkpoint Barrier对齐所花费的时间。 | ≥0 | 纳秒（ns） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_checkpointStartDelayNanos | 从Checkpoint创建到该Task开始处理Checkpoint Barrier之间的时间。 | ≥0 | 纳秒（ns） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_currentInputWatermark | Task当前输入Watermark。 | ≥0 | 毫秒（ms，时间戳） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_hardBackPressuredTimeMsPerSecond | 每秒Task处于硬反压状态的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_idleTimeMsPerSecond | 每秒Task处于空闲状态的时间，即没有数据可处理的时间；反压时间不计入空闲时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_initializationTime | Task Subtask初始化所花费的时间，包括状态恢复时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_mailboxLatencyMs | Mailbox消息处理延迟。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_mailboxMailsPerSecond | Mailbox每秒处理的消息数量。 | ≥0 | 个/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_mailboxQueueSize | Mailbox当前待处理消息数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_maxHardBackPressureTimeMs | 最近统计周期内单次硬反压的最大持续时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_maxSoftBackPressureTimeMs | 最近统计周期内单次软反压的最大持续时间。 | ≥0 | 毫秒（ms） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numBuffersInLocal | Task从同一TaskManager 内的其他Task接收的网络Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numBuffersInLocalPerSecond | Task每秒从同一TaskManager内的其他Task 接收的网络Buffer 数量。 | ≥0 | 个/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_numBuffersInRemote | Task从其他TaskManager接收的网络 Buffer 数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numBuffersInRemotePerSecond | Task每秒从其他TaskManager 接收的网络Buffer数量。 | ≥0 | 个/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_numBuffersOut | Task累计发出的网络Buffer数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numBuffersOutPerSecond | Task每秒发出的网络Buffer数量。 | ≥0 | 个/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesInLocal | Task从同一TaskManager内的其他 Task 接收的累计数据量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesInLocalPerSecond | Task每秒从同一TaskManager 内的其他Task接收的数据量。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesInRemote | Task从其他TaskManager 接收的累计数据量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numBytesInRemotePerSecond | Task每秒从其他TaskManager 接收的数据量。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_numFiredTimers | Task累计触发的Timer 数量。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_numFiredTimersPerSecond | Task每秒触发的Timer 数量。 | ≥0 | 个/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_coldStateBackendImpact | 该算子冷状态访问对状态后端的影响度（新版/定制引擎指标，未启用统计时为NaN）。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_currentInputWatermark | 该算子的当前输入Watermark。 | ≥0 | 毫秒（ms，时间戳） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_currentOutputWatermark | 该算子的当前输出Watermark。 | ≥0 | 毫秒（ms，时间戳） | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numBytesIn | Operator累计接收的数据量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numBytesInPerSecond | Operator每秒接收的数据量。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numBytesOut | Operator累计输出的数据量。 | ≥0 | 字节（Byte） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numBytesOutPerSecond | Operator每秒输出的数据量。 | ≥0 | 字节/秒（Byte/s） | 1024 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_numLateRecordsDropped | 窗口延迟丢弃数。 | ≥0 | 个 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_sink_numRecordsIn | SinkWriter累计接收的记录数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_sink_numRecordsInPerSecond | SinkWriter每秒接收的记录数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_source_numRecordsOut | SourceReader累计输出的记录数。 | ≥0 | 条 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_source_numRecordsOutPerSecond | SourceReader每秒输出的记录数。 | ≥0 | 条/秒 | 1000 | job_id, endpoint_id | | flink_taskmanager_job_task_operator_stateBackendImpact | 该算子状态访问对状态后端的影响度（新版/定制引擎指标，未启用统计时为NaN）。 | ≥0 | 无 | 不涉及 | job_id, endpoint_id | | flink_taskmanager_job_task_softBackPressuredTimeMsPerSecond | 每秒Task处于软反压状态的时间。 | ≥0 | 毫秒/秒 | 1000 | job_id, endpoint_id |