From 4c5be4740050fa29475c337dd8ce308d72c176fe Mon Sep 17 00:00:00 2001 From: discord9 Date: Wed, 22 Jul 2026 18:41:09 +0800 Subject: [PATCH] fix(flow): downgrade disabled incremental checkpoint log (#8572) Signed-off-by: discord9 --- src/flow/src/batching_mode/task/ckpt.rs | 9 +++++++++ 1 file changed, 9 insertions(+) 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,