不能向普罗米修斯公开flink度量

wh6knrhe 于 2021-06-21 发布在 Flink

关注(0)|答案(1)|浏览(485)

我正试图向普罗米修斯展示flink的内置指标，但不知何故普罗米修斯无法识别目标——jmx和普罗米修斯记者。
中定义的刮削 prometheus.yml 看起来像这样：

scrape_configs:
  - job_name: node
    static_configs:
      - targets: ['localhost:9100']

  - job_name: 'kafka-server'
    static_configs:
      - targets: ['localhost:7071']

  - job_name: 'flink-jmx'
    static_configs:
      - targets: ['localhost:8789']

  - job_name: 'flink-prom'
    static_configs:
      - targets: ['localhost:9249']

还有我的 flink-conf.yml 包含以下行：


# metrics.reporters: jmx, prom

metrics.reporters: jmx, prometheus

# metrics.reporter.jmx.factory.class: org.apache.flink.metrics.jmx.JMXReporterFactory

metrics.reporter.jmx.class: org.apache.flink.metrics.jmx.JMXReporter
metrics.reporter.jmx.port: 8789

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

但是，运行wordcount时，两个flink目标都已关闭
在intellij中
作为jar： java -jar target/flink-word-count.jar --input src/main/resources/loremipsum.txt 作为flink job： flink run target/flink-word-count.jar --input src/main/resources/loremipsum.txt 根据flink文档，我不需要jmx的任何附加依赖项和提供的 flink-metrics-prometheus-1.10.0.jar 在 flink/lib/ 普罗米修斯的记者。
我做错什么了？少了什么？

Java apache-flink prometheus JMX

来源：https://stackoverflow.com/questions/63934199/cant-expose-flink-metrics-to-prometheus

1条答案

按热度按时间

wrrgggsh1#

我相信那项工作很快就会完成。一旦你让设置工作，可能没有有趣的指标，因为作业没有运行足够长的时间，任何东西显示出来。
当您使用小型群集（如 java -jar ... )，的 flink-conf.yaml 文件没有被加载（除非你在工作中做了一些特别的事情来加载它）。另请注意，此文件通常具有 .yaml 扩展；我不确定如果 .yml 改为使用。
您可以检查jog管理器和任务管理器日志，以确保正在加载报告器。
fwiw，上次我这么做的时候，我使用了这个设置，这样我就可以从多个进程中获取：


# flink-conf.yaml

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


# prometheus.yml

scrape_configs:
  - job_name: 'flink'
    static_configs:
      - targets: ['localhost:9250', 'localhost:9251']

赞(0）回复(0）举报 2021-06-21

我来回答

不能向普罗米修斯公开flink度量

1条答案

相关问题

热门标签

最新问答