Flinkのメトリクスを見るためのjmx_expoterの設定

jmx_exporter_flink.yaml

---
hostPort: localhost:{{ item.jmx_port }}
lowercaseOutputName: true
lowercaseOutputLabelNames: false
whitelistObjectNames:
  - "java.lang:*"
  - "org.apache.flink.metrics:*"
rules:
  - pattern: "^java.lang.*"
# Kafka source
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=([^,]+), key2=([^,]+), key3=([^,]+), key4=([^,]+), key5=([^,]+), key6=KafkaConsumer, name=([^,]+)><>Value
    name: flink_kafkaconsumer_$7
    labels:
      host: $1
      component: $2
      jobid: $3
      jobname: $4
      taskid: $5:$6
# Taskmanager 
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=([^,]+), key2=([^,]+), key3=Status, key4=JVM, key5=CPU, name=Load><>Value
    name: flink_daemon_cpu_load
    labels:
      host: $1
      component: $2
      nodeid: $3
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=([^,]+), key2=([^,]+), key3=Status, key4=JVM, key5=CPU, name=Time><>Value
    name: flink_daemon_cpu_time
    labels:
      host: $1
      component: $2
      nodeid: $3
    type: COUNTER
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=taskmanager, key2=([^,]+), key3=Status, key4=JVM, key5=([^,]+), name=([^,]+)><>Value
    name: flink_taskmanager_jvm_$4
    labels:
      host: $1
      component: taskmanager
      taskmanagerid: $2
      key: $3
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=taskmanager, key2=([^,]+), key3=Status, key4=JVM, key5=([^,]+), key6=([^,]+), name=([^,]+)><>Value
    name: flink_taskmanager_jvm_$3_$5
    labels:
      host: $1
      component: taskmanager
      taskmanagerid: $2
      key: $4
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=taskmanager, key2=([^,]+), key3=([^,]+), key4=([^,]+), key5=([^,]+), name=([^,]+)><>Count
    name: flink_task_$6
    labels:
      host: $1
      component: taskmanager
      taskmanagerid: $2
      jobname: $3
      taskid: $4:$5
    type: COUNTER
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=taskmanager, key2=([^,]+), key3=([^,]+), key4=([^,]+), key5=([^,]+), name=([^,]+)><>Value
    name: flink_task_$6
    labels:
      host: $1
      component: taskmanager
      taskmanagerid: $2
      jobname: $3
      taskid: $4:$5
# JobManager
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=([^,]+), key2=Status, key3=JVM, key4=CPU, name=Time><>Value
    name: flink_daemon_cpu_time
    labels:
      host: $1
      component: $2
    type: COUNTER
  - pattern: org.apache.flink.metrics<key0=([^,]+), key1=([^,]+), key2=Status, key3=JVM, key4=CPU, name=Load><>Value
    name: flink_daemon_cpu_load
    labels:
      host: $1
      component: $2