clean up debug code

Author: dantengsky

src/query/service/src/interpreters/interpreter_insert.rs

@@ -485,8 +485,6 @@ impl Interpreter for InsertInterpreter {
 
                 let ctx = self.ctx.clone();
                 let overwrite = self.plan.overwrite;
-                eprintln!(">>> main piepline {:?}", build_res.main_pipeline);
-                eprintln!(">>> source piepline {:?}", build_res.sources_pipelines);
                 build_res.main_pipeline.set_on_finished(move |may_error| {
                     // capture out variable
                     let overwrite = overwrite;

src/query/service/src/schedulers/fragments/fragmenter.rs

@@ -94,9 +94,7 @@ impl Fragmenter {
     }
 
     pub fn build_fragment(mut self, plan: &PhysicalPlan) -> Result<PlanFragment> {
-        eprintln!("origin plan {:?}", &plan);
         let root = self.replace(plan)?;
-        eprintln!("after replace {:?}", &root);
         let mut root_fragment = PlanFragment {
             plan: root,
             fragment_type: FragmentType::Root,

src/query/storages/fuse/src/io/read/bloom/block_filter_reader.rs

@@ -82,13 +82,6 @@ async fn load_bloom_filter_by_columns<'a>(
 ) -> Result<BlockFilter> {
     // 1. load index meta
     let bloom_index_meta = load_index_meta(dal.clone(), index_path, index_length).await?;
-    // let file_meta = &bloom_index_meta.0;
-    // if file_meta.row_groups.len() != 1 {
-    //    return Err(ErrorCode::StorageOther(format!(
-    //        "invalid bloom filter index, number of row group should be 1, but found {} row groups",
-    //        file_meta.row_groups.len()
-    //    )));
-    //}
 
     // 2. filter out columns that needed and exist in the index
     // 2.1 dedup the columns

src/query/storages/fuse/src/io/read/bloom/column_filter_reader.rs

@@ -141,11 +141,6 @@ impl Loader<Xor8Filter> for Xor8FilterLoader {
             descriptor: self.column_descriptor.descriptor.clone(),
         };
 
-        eprintln!(
-            "column descriptor: {:?}",
-            self.column_descriptor.descriptor.clone()
-        );
-
         let page_reader = PageReader::new_with_page_meta(
             std::io::Cursor::new(bytes),
             page_meta_data,

src/query/storages/fuse/src/io/read/meta/meta_readers.rs

@@ -144,11 +144,8 @@ mod thrift_file_meta_read {
     use super::*;
 
     // the following code is copied from crate `parquet2`, with slight modification:
-    // return a ThriftFileMetaData instead of FileMetaData while reader parquet metadata,
+    // return a ThriftFileMetaData instead of FileMetaData while reading parquet metadata,
     // to avoid unnecessary conversions.
-    //
-    // It takes about 18s, to convert one million ThriftFileMetaData objects to parquet::metadata::FileMetaData,
-    // and the memory usage of FileMetaData is also larger.
 
     const HEADER_SIZE: u64 = PARQUET_MAGIC.len() as u64;
     const FOOTER_SIZE: u64 = 8;