How to Monitor Apache Flink With OpenTelemetry
flink.jvm.cpu.load
The CPU usage of the JVM for a jobmanager or taskmanager.
flink.jvm.cpu.time
The CPU time used by the JVM for a jobmanager or taskmanager.
flink.jvm.memory.heap.used
The amount of heap memory currently used.
flink.jvm.memory.heap.committed
The amount of heap memory guaranteed to be available to the JVM.
flink.jvm.memory.heap.max
The maximum amount of heap memory that can be used for memory management.
flink.jvm.memory.nonheap.used
The amount of non-heap memory currently used.
flink.jvm.memory.nonheap.committed
The amount of non-heap memory guaranteed to be available to the JVM.
flink.jvm.memory.nonheap.max
The maximum amount of non-heap memory that can be used for memory management.
flink.jvm.memory.metaspace.used
The amount of memory currently used in the Metaspace memory pool.
flink.jvm.memory.metaspace.committed
The amount of memory guaranteed to be available to the JVM in the Metaspace memory pool.
flink.jvm.memory.metaspace.max
The maximum amount of memory that can be used in the Metaspace memory pool.
flink.jvm.memory.direct.used
The amount of memory used by the JVM for the direct buffer pool.
flink.jvm.memory.direct.total_capacity
The total capacity of all buffers in the direct buffer pool.
flink.jvm.memory.mapped.used
The amount of memory used by the JVM for the mapped buffer pool.
flink.jvm.memory.mapped.total_capacity
The number of buffers in the mapped buffer pool.
flink.memory.managed.used
The amount of managed memory currently used.
flink.memory.managed.total
The total amount of managed memory.
flink.jvm.threads.count
The total number of live threads.
flink.jvm.gc.collections.count
The total number of collections that have occurred.
flink.jvm.gc.collections.time
The total time spent performing garbage collection.
flink.jvm.class_loader.classes_loaded
The total number of classes loaded since the start of the JVM.
flink.job.restart.count
The total number of restarts since this job was submitted, including full restarts and fine-grained restarts.
flink.job.last_checkpoint.time
The end to end duration of the last checkpoint.
flink.job.last_checkpoint.size
The total size of the last checkpoint.
flink.job.checkpoint.count
The number of checkpoints completed or failed.
flink.job.checkpoint.in_progress
The number of checkpoints in progress.
flink.task.record.count
The number of records a task has.
flink.operator.record.count
The number of records an operator has.
flink.operator.watermark.output
The last watermark this operator has emitted.