[gobblin] branch master updated: [GOBBLIN-1769] Change a noisy log that indicates that the queue capacity is almost full to debug (#3629)

[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 8ac032d55 [GOBBLIN-1769] Change a noisy log that indicates that the 
queue capacity is almost full to debug (#3629)
8ac032d55 is described below

commit 8ac032d551bfde63e42b80252456d948d22123e1
Author: William Lo <lo.willia...@gmail.com>
AuthorDate: Tue Jan 24 15:22:51 2023 -0800

    [GOBBLIN-1769] Change a noisy log that indicates that the queue capacity is 
almost full to debug (#3629)
---
 .../org/apache/gobblin/metrics/reporter/EventReporter.java    | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git 
a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java
 
b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java
index 45061ba55..94b8c4be4 100644
--- 
a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java
+++ 
b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java
@@ -17,9 +17,6 @@
 
 package org.apache.gobblin.metrics.reporter;
 
-import lombok.Getter;
-import lombok.extern.slf4j.Slf4j;
-
 import java.io.Closeable;
 import java.util.Map;
 import java.util.Queue;
@@ -31,8 +28,6 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 
-import javax.annotation.Nullable;
-
 import com.codahale.metrics.Counter;
 import com.codahale.metrics.Gauge;
 import com.codahale.metrics.Histogram;
@@ -51,6 +46,10 @@ import com.google.common.util.concurrent.MoreExecutors;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
+import javax.annotation.Nullable;
+import lombok.Getter;
+import lombok.extern.slf4j.Slf4j;
+
 import org.apache.gobblin.configuration.ConfigurationKeys;
 import org.apache.gobblin.metrics.GobblinTrackingEvent;
 import org.apache.gobblin.metrics.MetricContext;
@@ -141,7 +140,7 @@ public abstract class EventReporter extends 
ScheduledReporter implements Closeab
    */
   public void addEventToReportingQueue(GobblinTrackingEvent event) {
     if (this.reportingQueue.size() > this.queueCapacity * 2 / 3) {
-      log.info("Trigger immediate run to report the event since queue is 
almost full");
+      log.debug("Trigger immediate run to report the event since queue is 
almost full");
       immediatelyScheduleReport();
     }
     try {