????

2022-03-01 文章 Blake


????

2022-02-21 文章 Blake


[metrics] metrics ?? Availability ?? Checkpointing ??????????????

2019-10-22 文章 Blake
 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/