(gobblin) branch master updated: [GOBBLIN-2149] Add logs in OpenTelemetry for debugging (#4046)

[wlo]

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

wlo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 0ea241476c [GOBBLIN-2149] Add logs in OpenTelemetry for debugging 
(#4046)
0ea241476c is described below

commit 0ea241476cff6b7d8fe7cde0b088d656f32d87e4
Author: abhishekmjain <abhishekmjai...@gmail.com>
AuthorDate: Tue Sep 3 22:58:27 2024 +0530

    [GOBBLIN-2149] Add logs in OpenTelemetry for debugging (#4046)
---
 .../main/java/org/apache/gobblin/metrics/OpenTelemetryMetricsBase.java | 3 +++
 .../gobblin/service/monitoring/GaaSJobObservabilityEventProducer.java  | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetricsBase.java
 
b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetricsBase.java
index 42642af4ca..ef12d03825 100644
--- 
a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetricsBase.java
+++ 
b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetricsBase.java
@@ -24,10 +24,12 @@ import com.google.common.io.Closer;
 import io.opentelemetry.api.OpenTelemetry;
 import io.opentelemetry.api.metrics.Meter;
 import io.opentelemetry.sdk.metrics.export.MetricExporter;
+import lombok.extern.slf4j.Slf4j;
 
 import org.apache.gobblin.configuration.State;
 
 
+@Slf4j
 public abstract class OpenTelemetryMetricsBase implements AutoCloseable {
   protected MetricExporter metricExporter;
 
@@ -50,6 +52,7 @@ public abstract class OpenTelemetryMetricsBase implements 
AutoCloseable {
   }
 
   public void close() throws IOException {
+    log.info("Closing OpenTelemetryMetricsBase");
     if (this.closer != null) {
       this.closer.close();
     }
diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSJobObservabilityEventProducer.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSJobObservabilityEventProducer.java
index 4beafba29e..5f612547fc 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSJobObservabilityEventProducer.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSJobObservabilityEventProducer.java
@@ -120,7 +120,7 @@ public abstract class GaaSJobObservabilityEventProducer 
implements Closeable {
               int status = event.getJobStatus() == JobStatus.SUCCEEDED ? 1 : 0;
               this.jobStatusMetric.record(status, tags);
             }
-            log.debug("Submitted {} job status events", 
this.eventCollector.size());
+            log.info("Submitted {} job status events", 
this.eventCollector.size());
             // Empty the list of events as they are all emitted at this point.
             this.eventCollector.clear();
           }, this.jobStatusMetric);