This documentation has an index for AI agents at /llms.txt. A Markdown version of this page is available at https://explorer.opentelemetry.io/collector/components/contrib/flinkmetricsreceiver.md.

FlinkMetrics Receiver

OpenTelemetry Collector receiver · contrib distribution

This receiver uses Flink's REST API to collect Jobmanager, Taskmanager, Job, Task and Operator metrics.

  • Component ID: contrib-flinkmetricsreceiver
  • Name: flinkmetricsreceiver
  • Type: receiver
  • Distribution: contrib
  • Repository: opentelemetry-collector-contrib

Stability

LevelSignals
alphametrics

Metrics

MetricTypeValue typeUnitStabilityEnabledAttributesDescription
flink.job.checkpoint.countsum (monotonic)int{checkpoints}developmentyescheckpoint (string)The number of checkpoints completed or failed.
flink.job.checkpoint.in_progresssumint{checkpoints}developmentyesThe number of checkpoints in progress.
flink.job.last_checkpoint.sizesumintBydevelopmentyesThe total size of the last checkpoint.
flink.job.last_checkpoint.timegaugeintmsdevelopmentyesThe end to end duration of the last checkpoint.
flink.job.restart.countsum (monotonic)int{restarts}developmentyesThe total number of restarts since this job was submitted, including full restarts and fine-grained restarts.
flink.jvm.class_loader.classes_loadedsum (monotonic)int{classes}developmentyesThe total number of classes loaded since the start of the JVM.
flink.jvm.cpu.loadgaugedouble%developmentyesThe CPU usage of the JVM for a jobmanager or taskmanager.
flink.jvm.cpu.timesum (monotonic)intnsdevelopmentyesThe CPU time used by the JVM for a jobmanager or taskmanager.
flink.jvm.gc.collections.countsum (monotonic)int{collections}developmentyesgarbage_collector_name (string)The total number of collections that have occurred.
flink.jvm.gc.collections.timesum (monotonic)intmsdevelopmentyesgarbage_collector_name (string)The total time spent performing garbage collection.
flink.jvm.memory.direct.total_capacitysumintBydevelopmentyesThe total capacity of all buffers in the direct buffer pool.
flink.jvm.memory.direct.usedsumintBydevelopmentyesThe amount of memory used by the JVM for the direct buffer pool.
flink.jvm.memory.heap.committedsumintBydevelopmentyesThe amount of heap memory guaranteed to be available to the JVM.
flink.jvm.memory.heap.maxsumintBydevelopmentyesThe maximum amount of heap memory that can be used for memory management.
flink.jvm.memory.heap.usedsumintBydevelopmentyesThe amount of heap memory currently used.
flink.jvm.memory.mapped.total_capacitysumintBydevelopmentyesThe number of buffers in the mapped buffer pool.
flink.jvm.memory.mapped.usedsumintBydevelopmentyesThe amount of memory used by the JVM for the mapped buffer pool.
flink.jvm.memory.metaspace.committedsumintBydevelopmentyesThe amount of memory guaranteed to be available to the JVM in the Metaspace memory pool.
flink.jvm.memory.metaspace.maxsumintBydevelopmentyesThe maximum amount of memory that can be used in the Metaspace memory pool.
flink.jvm.memory.metaspace.usedsumintBydevelopmentyesThe amount of memory currently used in the Metaspace memory pool.
flink.jvm.memory.nonheap.committedsumintBydevelopmentyesThe amount of non-heap memory guaranteed to be available to the JVM.
flink.jvm.memory.nonheap.maxsumintBydevelopmentyesThe maximum amount of non-heap memory that can be used for memory management.
flink.jvm.memory.nonheap.usedsumintBydevelopmentyesThe amount of non-heap memory currently used.
flink.jvm.threads.countsumint{threads}developmentyesThe total number of live threads.
flink.memory.managed.totalsumintBydevelopmentyesThe total amount of managed memory.
flink.memory.managed.usedsumintBydevelopmentyesThe amount of managed memory currently used.
flink.operator.record.countsum (monotonic)int{records}developmentyesoperator_name (string), record (string)The number of records an operator has.
flink.operator.watermark.outputsumintmsdevelopmentyesoperator_name (string)The last watermark this operator has emitted.
flink.task.record.countsum (monotonic)int{records}developmentyesrecord (string)The number of records a task has.

Attributes

AttributeTypeDescription
checkpointstringThe number of checkpoints completed or that failed.
garbage_collector_namestringThe names for the parallel scavenge and garbage first garbage collectors.
operator_namestringThe operator name.
recordstringThe number of records received in, sent out or dropped due to arriving late.

Data

  • JSON (latest): /data/collector/components/contrib-flinkmetricsreceiver/latest.json
  • JSON (pinned): /data/collector/components/contrib-flinkmetricsreceiver/contrib-flinkmetricsreceiver-51d69e07b56f.json
  • Explore: /collector/components/contrib/flinkmetricsreceiver