fix

Author: SkyFan2002

src/query/service/src/interpreters/interpreter_append.rs

@@ -179,7 +179,11 @@ impl Interpreter for AppendInterpreter {
     }
 
     fn inject_result(&self) -> Result<SendableDataBlockStream> {
-        let append: Append = self.s_expr.plan().clone().try_into()?;
+        let append: Append = match &self.s_expr.plan() {
+            RelOperator::Append(append) => append.clone(),
+            RelOperator::Exchange(_) => self.s_expr.child(0).unwrap().plan().clone().try_into()?,
+            _ => unreachable!(),
+        };
         match &append.append_type {
             AppendType::CopyInto => {
                 let blocks = self.get_copy_into_table_result()?;

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

@@ -27,4 +27,5 @@ pub fn contains_local_table_scan(s_expr: &SExpr, metadata: &MetadataRef) -> bool
             false
         }
         || matches!(s_expr.plan(), RelOperator::RecursiveCteScan { .. })
+        || matches!(s_expr.plan(), RelOperator::ValueScan { .. })
 }

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

@@ -19,6 +19,9 @@ use crate::executor::physical_plans::PhysicalValueScan;
 use crate::executor::physical_plans::Values;
 use crate::executor::PhysicalPlan;
 use crate::executor::PhysicalPlanBuilder;
+use crate::optimizer::Distribution;
+use crate::optimizer::PhysicalProperty;
+use crate::optimizer::RelExpr;
 use crate::plans::Operator;
 use crate::plans::RelOp;
 
@@ -42,6 +45,12 @@ impl Operator for ValueScan {
     fn arity(&self) -> usize {
         0
     }
+
+    fn derive_physical_prop(&self, _rel_expr: &RelExpr) -> Result<PhysicalProperty> {
+        Ok(PhysicalProperty {
+            distribution: Distribution::Random,
+        })
+    }
 }
 
 impl PhysicalPlanBuilder {