refactor(interpreter): try fix test failure

Author: zhang2014

src/query/service/src/interpreters/interpreter_table_create_v2.rs

@@ -153,11 +153,10 @@ impl CreateTableInterpreterV2 {
             overwrite: false,
             source: InsertInputSource::SelectPlan(select_plan),
         };
-        let insert_interpreter_v2 =
-            InsertInterpreterV2::try_create(self.ctx.clone(), insert_plan, false)?;
-        insert_interpreter_v2.execute(self.ctx.clone()).await?;
 
-        Ok(PipelineBuildResult::create())
+        InsertInterpreterV2::try_create(self.ctx.clone(), insert_plan, false)?
+            .execute2()
+            .await
     }
 
     async fn create_table(&self) -> Result<PipelineBuildResult> {

src/query/service/tests/it/interpreters/interpreter_call.rs

@@ -121,7 +121,7 @@ async fn test_call_fuse_block_interpreter() -> Result<()> {
         let (plan, _, _) = planner.plan_sql(query).await?;
         let executor = InterpreterFactoryV2::get(ctx.clone(), &plan)?;
         assert_eq!(executor.name(), "CallInterpreter");
-        let res = executor.execute().await;
+        let res = executor.execute(ctx.clone()).await;
         assert_eq!(res.is_err(), true);
         let expect = "Code: 1028, displayText = Function `FUSE_BLOCK` expect to have [2, 3] arguments, but got 0.";
         assert_eq!(expect, res.err().unwrap().to_string());
@@ -133,7 +133,7 @@ async fn test_call_fuse_block_interpreter() -> Result<()> {
         let (plan, _, _) = planner.plan_sql(query).await?;
         let executor = InterpreterFactoryV2::get(ctx.clone(), &plan)?;
         assert_eq!(executor.name(), "CallInterpreter");
-        let res = executor.execute().await;
+        let res = executor.execute(ctx.clone()).await;
         assert_eq!(res.is_err(), true);
         assert_eq!(
             res.err().unwrap().code(),
@@ -147,7 +147,7 @@ async fn test_call_fuse_block_interpreter() -> Result<()> {
         let (plan, _, _) = planner.plan_sql(query).await?;
         let executor = InterpreterFactoryV2::get(ctx.clone(), &plan)?;
         assert_eq!(executor.name(), "CallInterpreter");
-        let res = executor.execute().await;
+        let res = executor.execute(ctx.clone()).await;
         assert_eq!(res.is_err(), true);
         let expect =
             "Code: 1015, displayText = expects table of engine FUSE, but got SystemTables.";
@@ -162,15 +162,15 @@ async fn test_call_fuse_block_interpreter() -> Result<()> {
 
         let (plan, _, _) = planner.plan_sql(query).await?;
         let executor = InterpreterFactoryV2::get(ctx.clone(), &plan)?;
-        let _ = executor.execute().await?;
+        let _ = executor.execute(ctx.clone()).await?;
     }
 
     // fuse_block
     {
         let query = "call system$fuse_block(default, a)";
         let (plan, _, _) = planner.plan_sql(query).await?;
         let executor = InterpreterFactoryV2::get(ctx.clone(), &plan)?;
-        let _ = executor.execute().await?;
+        let _ = executor.execute(ctx.clone()).await?;
     }
 
     Ok(())

src/query/service/tests/it/storages/fuse/table_functions/fuse_block_table.rs

@@ -32,7 +32,7 @@ async fn test_fuse_block_table() -> Result<()> {
     // test db & table
     let create_table_plan = fixture.default_crate_table_plan();
     let interpreter = CreateTableInterpreterV2::try_create(ctx.clone(), create_table_plan)?;
-    interpreter.execute().await?;
+    interpreter.execute(ctx.clone()).await?;
 
     {
         let expected = vec![