move some very verbose log messages to info

airbytehq · Feb 26, 2024 · 942a0f2 · 942a0f2
1 parent 55ac489
commit 942a0f2
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/...source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java b/...source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java
@@ -46,7 +46,7 @@ public AirbyteMessage saveState(final Map<String, String> offset, final SchemaHi
 
     final JsonNode asJson = Jsons.jsonNode(state);
 
-    LOGGER.info("debezium state: {}", asJson);
+    LOGGER.debug("debezium state: {}", asJson);
 
     final CdcState cdcState = new CdcState().withState(asJson);
     stateManager.getCdcStateManager().setCdcState(cdcState);

diff --git a/...-mssql/src/main/java/io/airbyte/integrations/source/mssql/cdc/MssqlDebeziumStateUtil.java b/...-mssql/src/main/java/io/airbyte/integrations/source/mssql/cdc/MssqlDebeziumStateUtil.java
@@ -125,7 +125,7 @@ public JsonNode constructInitialDebeziumState(final Properties properties,
     assert Objects.nonNull(schemaHistory.schema());
 
     final JsonNode asJson = serialize(offset, schemaHistory);
-    LOGGER.info("Initial Debezium state constructed: {}", asJson);
+    LOGGER.debug("Initial Debezium state constructed: {}", asJson);
 
     if (asJson.get(MssqlCdcStateConstants.MSSQL_DB_HISTORY).asText().isBlank()) {
       throw new RuntimeException("Schema history snapshot returned empty history.");

diff --git a/.../java/io/airbyte/integrations/source/mssql/initialsync/MssqlInitialSyncStateIterator.java b/.../java/io/airbyte/integrations/source/mssql/initialsync/MssqlInitialSyncStateIterator.java
@@ -92,7 +92,8 @@ protected AirbyteMessage computeNext() {
     } else if (!hasEmittedFinalState) {
       hasEmittedFinalState = true;
       final AirbyteStateMessage finalStateMessage = stateManager.createFinalStateMessage(pair, streamStateForIncrementalRun);
-      LOGGER.info("Finished initial sync of stream {}, Emitting final state, state is {}", pair, finalStateMessage);
+      LOGGER.info("Finished initial sync of stream {}, Emitting final state", pair);
+      LOGGER.debug("state is {}", finalStateMessage);
       return new AirbyteMessage()
           .withType(Type.STATE)
           .withState(finalStateMessage);