fix: reduce level of duplicate and noisy logging (#14412)

PalashDhabale · Oct 21, 2024 · 3d4b2c6 · 3d4b2c6
1 parent e1bb6a7
commit 3d4b2c6
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/airbyte-commons-worker/src/main/java/io/airbyte/workers/sync/WorkloadApiWorker.java b/airbyte-commons-worker/src/main/java/io/airbyte/workers/sync/WorkloadApiWorker.java
@@ -264,7 +264,7 @@ private ReplicationOutput getReplicationOutput(final String workloadId) {
       }
     });
 
-    log.info("Replication output for workload {} : {}", workloadId, output.orElse(null));
+    log.debug("Replication output for workload {} : {}", workloadId, output.orElse(null));
     return output.orElse(null);
   }
 

diff --git a/...-workers/src/main/java/io/airbyte/workers/temporal/sync/AsyncReplicationActivityImpl.java b/...-workers/src/main/java/io/airbyte/workers/temporal/sync/AsyncReplicationActivityImpl.java
@@ -238,12 +238,12 @@ private StandardSyncOutput finalizeOutput(final ReplicationActivityInput replica
     final StandardSyncOutput standardSyncOutput = reduceReplicationOutput(attemptOutput, metricAttributes);
 
     final String standardSyncOutputString = standardSyncOutput.toString();
-    LOGGER.info("sync summary: {}", standardSyncOutputString);
+    LOGGER.debug("sync summary: {}", standardSyncOutputString);
     if (standardSyncOutputString.length() > MAX_TEMPORAL_MESSAGE_SIZE) {
       LOGGER.error("Sync output exceeds the max temporal message size of {}, actual is {}.", MAX_TEMPORAL_MESSAGE_SIZE,
           standardSyncOutputString.length());
     } else {
-      LOGGER.info("Sync summary length: {}", standardSyncOutputString.length());
+      LOGGER.debug("Sync summary length: {}", standardSyncOutputString.length());
     }
 
     if (featureFlagClient.boolVariation(WriteOutputCatalogToObjectStorage.INSTANCE, new Connection(tracingContext.connectionId))) {

diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/sync/ReplicationActivityImpl.java b/airbyte-workers/src/main/java/io/airbyte/workers/temporal/sync/ReplicationActivityImpl.java
@@ -213,12 +213,12 @@ private StandardSyncOutput finalizeOutput(final ReplicationActivityInput replica
     final StandardSyncOutput standardSyncOutput = reduceReplicationOutput(attemptOutput, metricAttributes);
 
     final String standardSyncOutputString = standardSyncOutput.toString();
-    LOGGER.info("sync summary: {}", standardSyncOutputString);
+    LOGGER.debug("sync summary: {}", standardSyncOutputString);
     if (standardSyncOutputString.length() > MAX_TEMPORAL_MESSAGE_SIZE) {
       LOGGER.error("Sync output exceeds the max temporal message size of {}, actual is {}.", MAX_TEMPORAL_MESSAGE_SIZE,
           standardSyncOutputString.length());
     } else {
-      LOGGER.info("Sync summary length: {}", standardSyncOutputString.length());
+      LOGGER.debug("Sync summary length: {}", standardSyncOutputString.length());
     }
 
     if (featureFlagClient.boolVariation(WriteOutputCatalogToObjectStorage.INSTANCE, new Connection(tracingContext.connectionId))) {
-Original file line number
+Diff line change
@@ Expand Up @@
           }
         });
-        log.info("Replication output for workload {} : {}", workloadId, output.orElse(null));
+        log.debug("Replication output for workload {} : {}", workloadId, output.orElse(null));
         return output.orElse(null);
       }
@@ Expand Down @@