Skip to content

Commit f7e81e9

Browse files
committedFeb 23, 2024·
move some very verbose log messages to info
1 parent 3813364 commit f7e81e9

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed
 

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

+1-1
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/cdc/MssqlDebeziumStateUtil.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ public JsonNode constructInitialDebeziumState(final Properties properties,
125125
assert Objects.nonNull(schemaHistory.schema());
126126

127127
final JsonNode asJson = serialize(offset, schemaHistory);
128-
LOGGER.info("Initial Debezium state constructed: {}", asJson);
128+
LOGGER.debug("Initial Debezium state constructed: {}", asJson);
129129

130130
if (asJson.get(MssqlCdcStateConstants.MSSQL_DB_HISTORY).asText().isBlank()) {
131131
throw new RuntimeException("Schema history snapshot returned empty history.");

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

+2-1
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)
Please sign in to comment.