From 942a0f2b6ee7e1c7f92b6f08816d82106f11f8e0 Mon Sep 17 00:00:00 2001 From: Stephane Geneix Date: Wed, 21 Feb 2024 11:07:45 -0800 Subject: [PATCH] move some very verbose log messages to info --- .../integrations/source/mssql/MssqlCdcStateHandler.java | 2 +- .../integrations/source/mssql/cdc/MssqlDebeziumStateUtil.java | 2 +- .../mssql/initialsync/MssqlInitialSyncStateIterator.java | 3 ++- 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java b/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java index 709c1bc12690..c666c50f2394 100644 --- a/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java +++ b/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java @@ -46,7 +46,7 @@ public AirbyteMessage saveState(final Map 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/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/cdc/MssqlDebeziumStateUtil.java b/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/cdc/MssqlDebeziumStateUtil.java index f998fb5113bf..40cdf7efd82a 100644 --- a/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/cdc/MssqlDebeziumStateUtil.java +++ b/airbyte-integrations/connectors/source-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/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/initialsync/MssqlInitialSyncStateIterator.java b/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/initialsync/MssqlInitialSyncStateIterator.java index 0fe6a872f75b..b42a06e257d0 100644 --- a/airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/initialsync/MssqlInitialSyncStateIterator.java +++ b/airbyte-integrations/connectors/source-mssql/src/main/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);