Fix fill column source and target schema order

databendlabs · Nov 2, 2022 · a41f14a · a41f14a
1 parent 514a047
commit a41f14a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/query/service/src/pipelines/pipeline_builder.rs b/src/query/service/src/pipelines/pipeline_builder.rs
@@ -626,9 +626,9 @@ impl PipelineBuilder {
 
         // Fill missing columns.
         {
-            let target_schema = insert_schema;
-            let source_schema = &table.schema();
-            if target_schema != source_schema {
+            let source_schema = insert_schema;
+            let target_schema = &table.schema();
+            if source_schema != target_schema {
                 self.main_pipeline.add_transform(
                     |transform_input_port, transform_output_port| {
                         TransformAddOn::try_create(