Change a noisy log that indicates that the queue capacity is almost full to debug
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 {
