...
These JVM metrics are exposed and can be used through the JobManager's metrics REST API.
JVM | Metric | Used key | Total key | ||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
Heap | Status.JVM.Memory.Heap | Used | Max | ||||||||
Direct | Status.JVM.Memory.Direct | Used | Max | ||||||||
Mapped | Status.JVM.Memory.Mapped | MemoryUsed | TotalCapacity | ||||||||
NonHeap | Status.JVM.Memory.NonHeap | MemoryUsed | TotalCapacity | ||||||||
Metaspace | Status.JVM.Memory.Metaspace | Used | Max |
Memory Configuration
Flink's memory model (as described in org.apache.flink.runtime.jobmanager.JobManagerProcessSpec
) can be mapped to the following Flink configuration parameters. There are a few that have a correlating Flink metric.
Flink Memory Model | Flink configuration1 | REST API2 | Metric | Used key | Total key | ||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|
Heap | jobmanager.memory.heap.size | ??? | Status.JVM.Memory.Heap | Used | Max | ||||||||
Off-Heap | jobmanager.memory.off-heap.size | ??? | - | - | - | ||||||||
JVM Metaspace | jobmanager.memory.jvm-metaspace.size | ??? | Status.JVM.Memory.Metaspace | Used | Max | ||||||||
JVM Overhead | jobmanager.memory.jvm-overhead.min | ??? | - | - | - | ||||||||
jobmanager.memory.jvm-overhead.max |
1 These are the configuration parameters used in the Flink configuration.
2 These are the Json paths to address the properties in the HTTP REST API response. Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-19662
...