change severity of state delta tracker exception and clarify messaging (

airbytehq#9657)
frankfanslc · Jan 20, 2022 · 111131a · 111131a
1 parent 4c83ac1
commit 111131a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...yte-workers/src/main/java/io/airbyte/workers/protocols/airbyte/AirbyteMessageTracker.java b/...yte-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;
     }
   }