From 613c1c675de85c0d015f5be2c293d76db7b586ff Mon Sep 17 00:00:00 2001 From: discord9 Date: Sat, 5 Sep 2026 03:36:51 +0800 Subject: [PATCH] fix(flow): resolve incremental state clippy warnings Signed-off-by: discord9 --- src/flow/src/batching_mode/engine.rs | 13 ++++++------- src/flow/src/batching_mode/utils.rs | 2 +- 2 files changed, 7 insertions(+), 8 deletions(-) diff --git a/src/flow/src/batching_mode/engine.rs b/src/flow/src/batching_mode/engine.rs index c3a21d73a5..4c26b6c4b3 100644 --- a/src/flow/src/batching_mode/engine.rs +++ b/src/flow/src/batching_mode/engine.rs @@ -769,13 +769,12 @@ impl BatchingEngine { let persistence = if let Some(factory) = &self.persistence_factory { let table_info = table.table_info(); let meta = &table_info.meta; - let effective_mode = if task.config.exact_sequence_range_required { - crate::IncrementalMode::SequenceRange - } else if task.config.batch_opts.experimental_enable_incremental_read - && task - .sequence_range_capable() - .await - .is_ok_and(|capable| capable) + let effective_mode = if task.config.exact_sequence_range_required + || (task.config.batch_opts.experimental_enable_incremental_read + && task + .sequence_range_capable() + .await + .is_ok_and(|capable| capable)) { crate::IncrementalMode::SequenceRange } else { diff --git a/src/flow/src/batching_mode/utils.rs b/src/flow/src/batching_mode/utils.rs index 66256e3618..c09fc1ff40 100644 --- a/src/flow/src/batching_mode/utils.rs +++ b/src/flow/src/batching_mode/utils.rs @@ -547,7 +547,7 @@ pub fn analyze_incremental_aggregate_plan( merge_columns.push(IncrementalAggregateMergeColumn { input_field_name: input_field_name.clone(), output_field_name, - merge_op: merge_op.clone(), + merge_op, }); } }