Skip to content

Commit e73e2d0

Browse files
committed
fix
1 parent 41a175f commit e73e2d0

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

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

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -114,17 +114,13 @@ pub async fn create_append_plan_from_subquery(
114114

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

117-
let plan = Plan::Append {
117+
Plan::Append {
118118
s_expr: Box::new(optimized_append),
119119
metadata: metadata.clone(),
120120
stage_table_info: None,
121121
overwrite,
122122
forbid_occ_retry,
123-
};
124-
let opt_ctx = OptimizerContext::new(ctx.clone(), metadata)
125-
.with_enable_distributed_optimization(!ctx.get_cluster().is_empty());
126-
127-
optimize(opt_ctx, plan).await
123+
}
128124
}
129125

130126
impl Hash for Append {

0 commit comments

Comments
 (0)