diff --git a/src/flow/src/batching_mode/task/ckpt.rs b/src/flow/src/batching_mode/task/ckpt.rs index 9ec4c9a7b7..960e541c73 100644 --- a/src/flow/src/batching_mode/task/ckpt.rs +++ b/src/flow/src/batching_mode/task/ckpt.rs @@ -324,6 +324,15 @@ impl BatchingTask { "Flow {flow_id} continued fenced repair, pending_windows={pending_windows}, watermarks={watermarks}" ); } + FlowCheckpointDecision::FallbackToFullSnapshot { + previous_mode: CheckpointMode::FullSnapshot, + reason: FlowQueryFallbackReason::IncrementalDisabled, + } => { + debug!( + "Flow {flow_id} remains in full snapshot mode, reason={}", + FlowQueryFallbackReason::IncrementalDisabled.as_label() + ); + } FlowCheckpointDecision::FallbackToFullSnapshot { previous_mode, reason,