Skip to content

Commit

Permalink
Unify logging format
Browse files Browse the repository at this point in the history
  • Loading branch information
tuliren committed Aug 11, 2022
1 parent cd497bb commit c80eaee
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ protected AirbyteMessage computeNext() {
public AirbyteMessage createStateMessage(final boolean isFinalState) {
final AirbyteStateMessage stateMessage = stateManager.updateAndEmit(pair, maxCursor, maxCursorRecordCount);
final Optional<CursorInfo> cursorInfo = stateManager.getCursorInfo(pair);
LOGGER.info("State report for stream \"{}\": original cursor \"{}\": value \"{}\" (record count {}) -> new cursor \"{}\" - value \"{}\" (record count {})",
LOGGER.info("State report for stream \"{}\": original cursor \"{}\": value \"{}\" (record count {}) -> new cursor \"{}\": value \"{}\" (record count {})",
pair,
cursorInfo.map(CursorInfo::getOriginalCursorField).orElse(null),
cursorInfo.map(CursorInfo::getOriginalCursor).orElse(null),
Expand Down

0 comments on commit c80eaee

Please sign in to comment.