From 27e142e17179c52134030f12d78bdf84d5298a30 Mon Sep 17 00:00:00 2001 From: charlesdong1991 Date: Sun, 2 Aug 2026 16:05:21 +0200 Subject: [PATCH 1/2] Fix wrong hardcoded instrumentation scope --- .../apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java | 2 +- .../flink/metrics/otel/OpenTelemetryMetricReporterITCase.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java b/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java index a9ca35de7ae07..cdc8388cd2fd5 100644 --- a/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java +++ b/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java @@ -55,7 +55,7 @@ class OpenTelemetryMetricAdapter { static final double[] HISTOGRAM_QUANTILES = {0.5, 0.75, 0.95, 0.99}; static final InstrumentationScopeInfo INSTRUMENTATION_SCOPE_INFO = - InstrumentationScopeInfo.create("io.confluent.flink.common.metrics"); + InstrumentationScopeInfo.create(OpenTelemetryMetricAdapter.class.getPackage().getName()); public static Optional convertCounter( CollectionMetadata collectionMetadata, diff --git a/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryMetricReporterITCase.java b/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryMetricReporterITCase.java index 582a4c31511ac..8c54b768a5d56 100644 --- a/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryMetricReporterITCase.java +++ b/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryMetricReporterITCase.java @@ -103,7 +103,7 @@ public void testReport() throws Exception { JsonNode scopeMetrics = json.findPath("resourceMetrics").findPath("scopeMetrics"); assertThat(scopeMetrics.findPath("scope").findPath("name").asText()) - .isEqualTo("io.confluent.flink.common.metrics"); + .isEqualTo("org.apache.flink.metrics.otel"); JsonNode metrics = scopeMetrics.findPath("metrics"); List metricNames = extractMetricNames(json); From a252f3ecf44e399f5d6448cc27c7afdefceae773 Mon Sep 17 00:00:00 2001 From: charlesdong1991 Date: Sun, 2 Aug 2026 17:19:16 +0200 Subject: [PATCH 2/2] fix lint --- .../apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java b/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java index cdc8388cd2fd5..db0c72d8f5f31 100644 --- a/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java +++ b/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/metrics/otel/OpenTelemetryMetricAdapter.java @@ -55,7 +55,8 @@ class OpenTelemetryMetricAdapter { static final double[] HISTOGRAM_QUANTILES = {0.5, 0.75, 0.95, 0.99}; static final InstrumentationScopeInfo INSTRUMENTATION_SCOPE_INFO = - InstrumentationScopeInfo.create(OpenTelemetryMetricAdapter.class.getPackage().getName()); + InstrumentationScopeInfo.create( + OpenTelemetryMetricAdapter.class.getPackage().getName()); public static Optional convertCounter( CollectionMetadata collectionMetadata,