chore: fix copy/spill log message (#15482)

* chore: fix copy/spill log message

* fix query plan output, to avoid breakline

* add line by line log for physical log

Author: BohuTANG

src/query/service/src/interpreters/interpreter_select.rs

@@ -255,14 +255,12 @@ impl Interpreter for SelectInterpreter {
 
         // 0. Need to build physical plan first to get the partitions.
         let physical_plan = self.build_physical_plan().await?;
+
         let query_plan = physical_plan
             .format(self.metadata.clone(), Default::default())?
             .format_pretty()?;
-        info!(
-            "Query id: {}, query plan: {}",
-            self.ctx.get_id(),
-            query_plan
-        );
+
+        info!("Query physical plan: \n{}", query_plan);
 
         if self.ctx.get_settings().get_enable_query_result_cache()? && self.ctx.get_cacheable() {
             let key = gen_result_cache_key(self.formatted_ast.as_ref().unwrap());

src/query/service/src/pipelines/processors/transforms/hash_join/build_spill/transform_build_spill.rs

@@ -158,11 +158,10 @@ impl BuildSpillHandler {
             return Ok(HashJoinBuildStep::Spill);
         }
         if build_state.join_type() != JoinType::Cross {
-            info!(
-                "Processor: {}, spill info: {}",
-                processor_id,
-                self.spill_state().spiller.format_spill_info()
-            );
+            let spill_info = self.spill_state().spiller.format_spill_info();
+            if !spill_info.is_empty() {
+                info!("Processor: {}, spill info: {}", processor_id, spill_info);
+            }
         }
         if !spilled_partition_set.is_empty() {
             build_state

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

@@ -228,15 +228,15 @@ impl CopyIntoTablePlan {
             (files_to_copy, duplicated_files)
         };
 
-        let len = need_copy_file_infos.len();
-        let sum: u64 = need_copy_file_infos.iter().map(|i| i.size).sum();
+        let num_copied_files = need_copy_file_infos.len();
+        let copied_bytes: u64 = need_copy_file_infos.iter().map(|i| i.size).sum();
 
         info!(
             "collect files with max_files={:?} finished, need to copy {} files, {} bytes; skip {} duplicated files, time used:{:?}",
             max_files,
             need_copy_file_infos.len(),
-            num_all_files - len,
-            sum,
+            copied_bytes,
+            num_all_files - num_copied_files,
             start.elapsed()
         );