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 <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