0

我们有一些工作的 Flink 作业，在 YARN 集群中运行。Flink 版本是 1.7.2。我想设置 Prometheus 监控来收集 Flinks 内置指标。完成本指南中的几个步骤后：https ://nightlies.apache.org/flink/flink-docs-release-1.7/monitoring/metrics.html#prometheus-orgapacheflinkmetricsprometheusprometheusreporter我设法让 Prometheus 激活并收集了一些指标. 但在分析 Flinks 日志后，我发现了一些有趣的警告：

2021-11-22 14:36:49,417 WARN org.apache.flink.metrics.MetricGroup - 名称冲突：组已经包含一个名为“request-size-max”的指标。Metric 不会上报。[server-node6, taskmanager, container_1635340399187_0068_01_000002, Job Name (1,8,12,24,25,26,2818,2823) (0.4.09.4-jarName), Sink: DATA kpi, 0, KafkaProducer ]
2021-11-22 14:36:49,418 WARN org.apache.flink.metrics.MetricGroup - 名称冲突：组已经包含一个名为 'outgoing-byte-total' 的 Metric。Metric 不会上报。[server-node6, taskmanager, container_1635340399187_0068_01_000002, Job Name (1,8,12,24,25,26,2818,2823) (0.4.09.4-jarName), Sink: DATA kpi, 0, KafkaProducer ]
2021-11-22 14:36:49,418 WARN org.apache.flink.metrics.MetricGroup - 名称冲突：组已经包含一个名为“请求率”的指标。Metric 不会上报。[server-node6, taskmanager, container_1635340399187_0068_01_000002, Job Name (1,8,12,24,25,26,2818,2823) (0.4.09.4-jarName), Sink: DATA kpi, 0, KafkaProducer ]
2021-11-22 14:36:49,418 WARN org.apache.flink.metrics.MetricGroup - 名称冲突：组已经包含一个名为“request-latency-avg”的指标。Metric 不会上报。[server-node6, taskmanager, container_1635340399187_0068_01_000002, Job Name (1,8,12,24,25,26,2818,2823) (0.4.09.4-jarName), Sink: DATA kpi, 0, KafkaProducer ]
2021-11-22 14:36:49,418 WARN org.apache.flink.metrics.MetricGroup - 名称冲突：组已经包含一个名为“request-total”的指标。Metric 不会上报。[server-node6, taskmanager, container_1635340399187_0068_01_000002, Job Name (1,8,12,24,25,26,2818,2823) (0.4.09.4-jarName), Sink: DATA kpi, 0, KafkaProducer ]
2021-11-22 14:36:49,418 WARN org.apache.flink.metrics.MetricGroup - 名称冲突：组已经包含一个名为“传入字节率”的指标。Metric 不会上报。[server-node6, taskmanager, container_1635340399187_0068_01_000002, Job Name (1,8,12,24,25,26,2818,2823) (0.4.09.4-jarName), Sink: DATA kpi, 0, KafkaProducer ]
2021-11-22 14:36:49,418 WARN org.apache.flink.metrics.MetricGroup - 名称冲突：组已经包含一个名为“response-total”的指标。Metric 不会上报。[server-node6, taskmanager, container_1635340399187_0068_01_000002, Job Name (1,8,12,24,25,26,2818,2823) (0.4.09.4-jarName), Sink: DATA kpi, 0, KafkaProducer ]

我想知道，这些警告的原因可能是什么。起初，我以为是激活了 Prometheus 报告器引起的。但是关闭记者后，这些警告仍然存在，所以肯定有其他原因。注意：Kafka 接收器的名称已设置。在同一个工作中，我们还有其他 Kafka 接收器，它们不会出现这些警告。

4

0 回答 0