Skip to content

Commit fd89e6d

Browse files
committed
fix modify column
1 parent 5c4dafb commit fd89e6d

File tree

3 files changed

+4
-1
lines changed

3 files changed

+4
-1
lines changed

src/query/service/src/interpreters/interpreter_table_create.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -233,6 +233,7 @@ impl CreateTableInterpreter {
233233
Arc::new(self.plan.schema.clone().into()),
234234
false,
235235
self.ctx.clone(),
236+
false,
236237
)
237238
.await?;
238239
let mut pipeline = InterpreterFactory::get(self.ctx.clone(), &append_plan)

src/query/service/src/interpreters/interpreter_table_modify_column.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -360,6 +360,7 @@ impl ModifyTableColumnInterpreter {
360360
Arc::new(DataSchema::from(&new_schema)),
361361
true,
362362
self.ctx.clone(),
363+
true,
363364
)
364365
.await?;
365366
InterpreterFactory::get(self.ctx.clone(), &append_plan)

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,7 @@ pub async fn create_append_plan_from_subquery(
7575
target_schema: DataSchemaRef,
7676
forbid_occ_retry: bool,
7777
ctx: Arc<dyn TableContext>,
78+
overwrite: bool,
7879
) -> Result<Plan> {
7980
let (project_columns, source, metadata) = match subquery {
8081
Plan::Query {
@@ -115,7 +116,7 @@ pub async fn create_append_plan_from_subquery(
115116
s_expr: Box::new(s_expr),
116117
metadata: metadata.clone(),
117118
stage_table_info: None,
118-
overwrite: false,
119+
overwrite,
119120
forbid_occ_retry,
120121
};
121122
let opt_ctx = OptimizerContext::new(ctx.clone(), metadata)

0 commit comments

Comments
 (0)