Skip to content

Commit e586a43

Browse files
committed
make lint
1 parent e73e2d0 commit e586a43

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

src/query/sql/src/planner/optimizer/optimizer.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -611,6 +611,9 @@ pub fn optimize_append(
611611
let exchange = Arc::new(RelOperator::Exchange(Exchange::Merge));
612612
Ok(SExpr::create_unary(exchange, Arc::new(copy_into)))
613613
}
614-
false => Ok(SExpr::create_unary(Arc::new(append.into()), Arc::new(source))),
614+
false => Ok(SExpr::create_unary(
615+
Arc::new(append.into()),
616+
Arc::new(source),
617+
)),
615618
}
616619
}

src/query/sql/src/planner/plans/append.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,7 @@ use super::RelOp;
4343
use crate::executor::physical_plans::PhysicalAppend;
4444
use crate::executor::PhysicalPlan;
4545
use crate::executor::PhysicalPlanBuilder;
46-
use crate::optimizer::optimize;
4746
use crate::optimizer::optimize_append;
48-
use crate::optimizer::OptimizerContext;
4947
use crate::optimizer::SExpr;
5048
use crate::ColumnBinding;
5149
use crate::IndexType;
@@ -114,13 +112,13 @@ pub async fn create_append_plan_from_subquery(
114112

115113
let optimized_append = optimize_append(insert_plan, source, metadata.clone(), ctx.as_ref())?;
116114

117-
Plan::Append {
115+
Ok(Plan::Append {
118116
s_expr: Box::new(optimized_append),
119117
metadata: metadata.clone(),
120118
stage_table_info: None,
121119
overwrite,
122120
forbid_occ_retry,
123-
}
121+
})
124122
}
125123

126124
impl Hash for Append {

0 commit comments

Comments
 (0)