Skip to content

Commit 7038bba

Browse files
move some very verbose log messages to info
1 parent f052c7c commit 7038bba

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public AirbyteMessage saveState(final Map<String, String> offset, final SchemaHi
4646

4747
final JsonNode asJson = Jsons.jsonNode(state);
4848

49-
LOGGER.info("debezium state: {}", asJson);
49+
LOGGER.debug("debezium state: {}", asJson);
5050

5151
final CdcState cdcState = new CdcState().withState(asJson);
5252
stateManager.getCdcStateManager().setCdcState(cdcState);

airbyte-integrations/connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/initialsync/MssqlInitialSyncStateIterator.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,8 @@ protected AirbyteMessage computeNext() {
9292
} else if (!hasEmittedFinalState) {
9393
hasEmittedFinalState = true;
9494
final AirbyteStateMessage finalStateMessage = stateManager.createFinalStateMessage(pair, streamStateForIncrementalRun);
95-
LOGGER.info("Finished initial sync of stream {}, Emitting final state, state is {}", pair, finalStateMessage);
95+
LOGGER.info("Finished initial sync of stream {}, Emitting final state", pair);
96+
LOGGER.debug("state is {}", finalStateMessage);
9697
return new AirbyteMessage()
9798
.withType(Type.STATE)
9899
.withState(finalStateMessage);

0 commit comments

Comments
 (0)