resolve conflict

databendlabs · Oct 15, 2023 · 338038d · 338038d
1 parent 7b293d4
commit 338038d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/query/service/src/interpreters/interpreter_table_recluster.rs b/src/query/service/src/interpreters/interpreter_table_recluster.rs
@@ -230,11 +230,11 @@ pub fn build_recluster_physical_plan(
     removed_segment_summary: Statistics,
 ) -> Result<PhysicalPlan> {
     let is_distributed = tasks.len() > 1;
-    let mut root = PhysicalPlan::ReclusterSource(ReclusterSource {
+    let mut root = PhysicalPlan::ReclusterSource(Box::new(ReclusterSource {
         tasks,
         table_info: table_info.clone(),
         catalog_info: catalog_info.clone(),
-    });
+    }));
 
     if is_distributed {
         root = PhysicalPlan::Exchange(Exchange {
@@ -246,13 +246,13 @@ pub fn build_recluster_physical_plan(
         });
     }
 
-    Ok(PhysicalPlan::ReclusterSink(ReclusterSink {
+    Ok(PhysicalPlan::ReclusterSink(Box::new(ReclusterSink {
         input: Box::new(root),
         table_info,
         catalog_info,
         snapshot,
         remained_blocks,
         removed_segment_indexes,
         removed_segment_summary,
-    }))
+    })))
 }
diff --git a/src/query/service/src/schedulers/fragments/plan_fragment.rs b/src/query/service/src/schedulers/fragments/plan_fragment.rs
@@ -458,10 +458,10 @@ struct ReplaceReclusterSource {
 
 impl PhysicalPlanReplacer for ReplaceReclusterSource {
     fn replace_recluster_source(&mut self, plan: &ReclusterSource) -> Result<PhysicalPlan> {
-        Ok(PhysicalPlan::ReclusterSource(ReclusterSource {
+        Ok(PhysicalPlan::ReclusterSource(Box::new(ReclusterSource {
             tasks: vec![self.task.clone()],
             ..plan.clone()
-        }))
+        })))
     }
 }