diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/protocols/airbyte/AirbyteMessageTracker.java b/airbyte-workers/src/main/java/io/airbyte/workers/protocols/airbyte/AirbyteMessageTracker.java index 4d4f93ed6f0a..f020778e3e2b 100644 --- a/airbyte-workers/src/main/java/io/airbyte/workers/protocols/airbyte/AirbyteMessageTracker.java +++ b/airbyte-workers/src/main/java/io/airbyte/workers/protocols/airbyte/AirbyteMessageTracker.java @@ -117,7 +117,9 @@ private void handleSourceEmittedState(final AirbyteStateMessage stateMessage) { stateDeltaTracker.addState(stateHash, streamToRunningCount); } } catch (final StateDeltaTrackerException e) { - log.error(e.getMessage(), e); + log.warn("The message tracker encountered an issue that prevents committed record counts from being reliably computed."); + log.warn("This only impacts metadata and does not indicate a problem with actual sync data."); + log.warn(e.getMessage(), e); unreliableCommittedCounts = true; } streamToRunningCount.clear(); @@ -134,7 +136,9 @@ private void handleDestinationEmittedState(final AirbyteStateMessage stateMessag stateDeltaTracker.commitStateHash(getStateHashCode(stateMessage)); } } catch (final StateDeltaTrackerException e) { - log.error(e.getMessage(), e); + log.warn("The message tracker encountered an issue that prevents committed record counts from being reliably computed."); + log.warn("This only impacts metadata and does not indicate a problem with actual sync data."); + log.warn(e.getMessage(), e); unreliableCommittedCounts = true; } }