使用 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:
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
command: jobmanager environment: - JOB_MANAGER_RPC_ADDRESS=jobmanager taskmanager:
build: ./task_manager container_name: taskmanager_1.9.0 ports:
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邮件归档
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邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。