(flink) branch master updated: [FLINK-39425][metrics] `OpenTelemetryEventReporter` ignores `service.name` and `service.version config`

[snuyanzin]

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

snuyanzin 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 692507671e8 [FLINK-39425][metrics] `OpenTelemetryEventReporter` 
ignores `service.name` and `service.version config`
692507671e8 is described below

commit 692507671e8a65e6c803a053c0b53c725fe9b91d
Author: SameerDevgon <49345451+sameerdev...@users.noreply.github.com>
AuthorDate: Fri May 29 01:38:21 2026 +0530

    [FLINK-39425][metrics] `OpenTelemetryEventReporter` ignores `service.name` 
and `service.version config`
---
 .../events/otel/OpenTelemetryEventReporter.java    |  1 +
 .../otel/OpenTelemetryEventReporterTest.java       | 23 ++++++++++++++++++++++
 2 files changed, 24 insertions(+)

diff --git 
a/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/events/otel/OpenTelemetryEventReporter.java
 
b/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/events/otel/OpenTelemetryEventReporter.java
index c7bc33402b3..748342d191d 100644
--- 
a/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/events/otel/OpenTelemetryEventReporter.java
+++ 
b/flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/events/otel/OpenTelemetryEventReporter.java
@@ -65,6 +65,7 @@ public class OpenTelemetryEventReporter extends 
OpenTelemetryReporterBase implem
     @Override
     public void open(MetricConfig metricConfig) {
         LOG.info("Starting OpenTelemetryEventReporter");
+        super.open(metricConfig);
         final String protocol =
                 Optional.ofNullable(
                                 metricConfig.getProperty(
diff --git 
a/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryEventReporterTest.java
 
b/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryEventReporterTest.java
index dc49d9fdf82..dd7b87c2aa0 100644
--- 
a/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryEventReporterTest.java
+++ 
b/flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryEventReporterTest.java
@@ -31,7 +31,9 @@ import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -55,6 +57,14 @@ public class OpenTelemetryEventReporterTest extends 
OpenTelemetryTestBase {
     @Test
     public void testReportLogRecord() throws Exception {
         MetricConfig metricConfig = createMetricConfig();
+
+        String serviceName = "flink-job";
+        String serviceVersion = "1.0.0";
+
+        
metricConfig.setProperty(OpenTelemetryReporterOptions.SERVICE_NAME.key(), 
serviceName);
+        metricConfig.setProperty(
+                OpenTelemetryReporterOptions.SERVICE_VERSION.key(), 
serviceVersion);
+
         String scope = this.getClass().getCanonicalName();
         String attribute1Key = "foo";
         String attribute1Value = "bar";
@@ -100,6 +110,19 @@ public class OpenTelemetryEventReporterTest extends 
OpenTelemetryTestBase {
 
         eventuallyConsumeJson(
                 (json) -> {
+                    Map<String, String> resourceAttributes = new HashMap<>();
+                    json.findPath("resourceLogs")
+                            .findPath("resource")
+                            .findPath("attributes")
+                            .forEach(
+                                    attribute ->
+                                            resourceAttributes.put(
+                                                    
attribute.get("key").asText(),
+                                                    
attribute.at("/value/stringValue").asText()));
+                    assertThat(resourceAttributes)
+                            .containsEntry("service.name", serviceName)
+                            .containsEntry("service.version", serviceVersion);
+
                     JsonNode resourceLogs = 
json.findPath("resourceLogs").findPath("scopeLogs");
                     
assertThat(resourceLogs.findPath("scope").findPath("name").asText())
                             .isEqualTo(scope);