From 111131a193359027d0081de1290eb4bb846662ef Mon Sep 17 00:00:00 2001 From: Parker Mossman Date: Thu, 20 Jan 2022 14:42:33 -0800 Subject: [PATCH] change severity of state delta tracker exception and clarify messaging (#9657) --- .../workers/protocols/airbyte/AirbyteMessageTracker.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) 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; } }