remove static filter

databendlabs · Dec 14, 2023 · cf6a395 · cf6a395
1 parent 992daee
commit cf6a395
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 541 deletions.
diff --git a/src/query/service/src/interpreters/interpreter_merge_into.rs b/src/query/service/src/interpreters/interpreter_merge_into.rs
@@ -188,14 +188,10 @@ impl MergeIntoInterpreter {
             input
         };
 
-        let optimized_input =
-            Self::build_static_filter(&input, meta_data, self.ctx.clone(), check_table).await?;
         let mut builder = PhysicalPlanBuilder::new(meta_data.clone(), self.ctx.clone(), false);
 
         // build source for MergeInto
-        let join_input = builder
-            .build(&optimized_input, *columns_set.clone())
-            .await?;
+        let join_input = builder.build(&input, *columns_set.clone()).await?;
 
         // find row_id column index
         let join_output_schema = join_input.output_schema()?;