[flink] branch master updated: [FLINK-30383][datadog] Add "flink." prefix to logical identifier

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 97509a13bf2 [FLINK-30383][datadog] Add "flink." prefix to logical 
identifier
97509a13bf2 is described below

commit 97509a13bf2aee219873c22e47ce67decfb09c5a
Author: Chesnay Schepler <ches...@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