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 a9ca35de7ae07e..db0c72d8f5f318 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("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 582a4c31511acf..8c54b768a5d56e 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);