???? PrometheusReporter  ?? report metric ????
??????9250 ???? ???????? Availability ?? Checkpointing ??????????????
??????????????????????????????????????????????
?????????????????? scope ???? Job ??only available on JobManager??
????????????????????????????????




??????????
flink-conf.yml
metrics.reporters: prom

metrics.reporter.prom.class: 
org.apache.flink.metrics.prometheus.PrometheusReporter
metrics.reporter.prom.port: 9250

metrics.system-resource: true







docker-compose.yml ??????
services:
  jobmanager:
    # image: flink:1.9.0
    build: ./job_manager
    container_name: jobmanager_1.9.0
    volumes:
      - ./prometheus/:/etc/prometheus/
      - prometheus_data:/prometheus
    ports:
      - "8081:8081"
      - "9250:9250"
    expose:
      - "6123"
    networks:
      - back-tier
      # - host-tier
    command: jobmanager
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager
  taskmanager:
    # image: flink:1.9.0
    build: ./task_manager
    container_name: taskmanager_1.9.0
    ports:
      # - "9001:9001"
      - "9251:9251"
    expose:
      - "6121"
      - "6122"
    networks:
      - back-tier
      # - host-tier
    command: taskmanager
    depends_on: 
      - jobmanager
    environment: 
      - JOB_MANAGER_RPC_ADDRESS=jobmanager




Docker
FROM flink:1.9.0

COPY flink-conf.yaml ./conf/

RUN cp ./opt/flink-metrics-prometheus-1.9.0.jar ./lib/

回复