开发者社区> 问答> 正文

[metrics] metrics 中 Availability 和 Checkpointing 这

使用 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/*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-08 10:15:23 613 0
1 条回答
写回答
取消 提交回答
  • JM 的 metric 应该也会直接 report。 可以考虑缩小下问题范围,是 metrics 还是 reporter 的问题。 例如加个 slf4j reporter [1],看下 JM log 中有没有相应的 metrics,如果有那就是 reporter 的问题。

    [1] https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/metrics.html#slf4j-orgapacheflinkmetricsslf4jslf4jreporter*来自志愿者整理的flink邮件归档

    2021-12-08 11:07:54
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Homologous Spark Clusters Using Nomad 立即下载
Serving Billions of Queries In Millisecond Latency 立即下载
Serving billions of queries in millisecond latency 立即下载