为什么Flink使用Push网关而不是Prometheus通常用于一般指标收集的拉动模型？

Question

我们可以看到，当将Flink指标暴露给外部系统（如Prometheus）时，Flink使用Push网关而不是Prometheus通常用于一般指标收集的拉取模型。

@Override
public void report() {
    try {
        pushGateway.push(CollectorRegistry.defaultRegistry, jobName);
    } catch (Exception e) {
        log.warn("Failed to push metrics to PushGateway with jobName {}.", jobName, e);
    }
}

https://github.com/apache/flink/blob/master/flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java

然而，普罗米修斯下面的官方文件指出，“普罗米修斯直接或通过中间推送网关从工具化作业中获取短期作业的指标”，显然Flink流式作业不是短期作业，那么为什么Flink使用推送网关而不是普罗米修斯通常的拉式模型来收集一般指标呢？

https://prometheus.io/docs/introduction/overview/

Answer 1

Flink提供了PrometheusPushGatewayReporter和通常更合适的基于pull的PrometheusReporter。普罗米修斯（Prometheus）在Flink用户中很受欢迎，社区对支持这两种类型的连接很感兴趣。