diff --git a/src/sql-server-util/src/cdc.rs b/src/sql-server-util/src/cdc.rs index c48f0c5f92480..ca313b783cfc2 100644 --- a/src/sql-server-util/src/cdc.rs +++ b/src/sql-server-util/src/cdc.rs @@ -282,7 +282,7 @@ impl<'a, M: SqlServerCdcMetrics> CdcStream<'a, M> { if db_max_lsn > curr_lsn { for (instance, instance_lsn) in &self.capture_instances { let Some(instance_lsn) = instance_lsn.as_ref() else { - tracing::error!(?instance, "found uninitialized LSN!"); + tracing::warn!(?instance, "found uninitialized LSN!"); continue; }; diff --git a/src/storage/src/source/sql_server/progress.rs b/src/storage/src/source/sql_server/progress.rs index a1db4508c528f..6bd083e80a652 100644 --- a/src/storage/src/source/sql_server/progress.rs +++ b/src/storage/src/source/sql_server/progress.rs @@ -150,7 +150,7 @@ pub(crate) fn render>( Some(prev) => prev, }; if known_lsn < prev_known_lsn { - mz_ore::soft_panic_or_log!( + tracing::warn!( "upstream SQL Server went backwards \ in time, current LSN: {known_lsn}, \ last known {prev_known_lsn}",