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