Skip to content

move some very verbose log messages to debug #35510

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 1 commit into from
Closed

move some very verbose log messages to debug #35510

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ...source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
2 changes: 1 addition & 1 deletion ...-mssql/src/main/java/io/airbyte/integrations/source/mssql/cdc/MssqlDebeziumStateUtil.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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.");
Expand Down
3 changes: 2 additions & 1 deletion .../java/io/airbyte/integrations/source/mssql/initialsync/MssqlInitialSyncStateIterator.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down