fix(copy): fix copy abort not in history. (#11102)

Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>

src/query/service/src/interpreters/interpreter_copy.rs

@@ -205,22 +205,29 @@ impl CopyInterpreter {
         )?;
 
         build_res.main_pipeline.set_on_finished(move |may_error| {
-            if may_error.is_none() {
-                CopyInterpreter::commit_copy_into_table(
-                    ctx.clone(),
-                    to_table,
-                    stage_info,
-                    need_copy_file_infos,
-                    force,
-                )?;
-                // Status.
-                {
-                    info!("all copy finished, elapsed:{}", start.elapsed().as_secs());
+            match may_error {
+                None => {
+                    CopyInterpreter::commit_copy_into_table(
+                        ctx.clone(),
+                        to_table,
+                        stage_info,
+                        need_copy_file_infos,
+                        force,
+                    )?;
+                    // Status.
+                    {
+                        info!("all copy finished, elapsed:{}", start.elapsed().as_secs());
+                    }
+                }
+                Some(error) => {
+                    error!(
+                        "copy failed, elapsed:{}, reason: {}",
+                        start.elapsed().as_secs(),
+                        error
+                    );
                 }
-                Ok(())
-            } else {
-                Err(may_error.as_ref().unwrap().clone())
             }
+            Ok(())
         });
 
         Ok(build_res)
@@ -382,22 +389,29 @@ impl CopyInterpreter {
 
         let stage_table_info_clone = stage_table_info.clone();
         build_res.main_pipeline.set_on_finished(move |may_error| {
-            if may_error.is_none() {
-                CopyInterpreter::commit_copy_into_table(
-                    ctx.clone(),
-                    to_table,
-                    stage_table_info_clone.stage_info,
-                    need_copy_file_infos,
-                    force,
-                )?;
-                // Status.
-                {
-                    info!("all copy finished, elapsed:{}", start.elapsed().as_secs());
+            match may_error {
+                None => {
+                    CopyInterpreter::commit_copy_into_table(
+                        ctx.clone(),
+                        to_table,
+                        stage_table_info_clone.stage_info,
+                        need_copy_file_infos,
+                        force,
+                    )?;
+                    // Status.
+                    {
+                        info!("all copy finished, elapsed:{}", start.elapsed().as_secs());
+                    }
+                }
+                Some(error) => {
+                    error!(
+                        "copy failed, elapsed:{}, reason: {}",
+                        start.elapsed().as_secs(),
+                        error
+                    );
                 }
-                Ok(())
-            } else {
-                Err(may_error.as_ref().unwrap().clone())
             }
+            Ok(())
         });
 
         Ok(build_res)