You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/12/19 11:49:51 UTC
[flink] branch release-1.16 updated: [FLINK-30383][datadog] Add "flink." prefix to logical identifier
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.16 by this push:
new 0293c3b998a [FLINK-30383][datadog] Add "flink." prefix to logical identifier
0293c3b998a is described below
commit 0293c3b998a75cc6a3ac1c8fa13d6d69b7f0d306
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Wed Dec 14 17:30:39 2022 +0100
[FLINK-30383][datadog] Add "flink." prefix to logical identifier
---
.../java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java b/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
index 5778728db2e..8b458730f3c 100644
--- a/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
+++ b/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
@@ -88,7 +88,8 @@ public class DatadogHttpReporter implements MetricReporter, Scheduled {
public void notifyOfAddedMetric(Metric metric, String metricName, MetricGroup group) {
final String name =
this.useLogicalIdentifier
- ? ((LogicalScopeProvider) group)
+ ? "flink."
+ + ((LogicalScopeProvider) group)
.getLogicalScope(CharacterFilter.NO_OP_FILTER)
+ "."
+ metricName