cargo fmt

databendlabs · Oct 24, 2024 · 41789c1 · 41789c1
1 parent 595dde9
commit 41789c1
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/src/query/storages/fuse/src/operations/read_partitions.rs b/src/query/storages/fuse/src/operations/read_partitions.rs
@@ -85,7 +85,7 @@ impl FuseTable {
                     nodes_num = cluster.nodes.len();
                 }
                 let enable_prune_pipeline = ctx.get_settings().get_enable_prune_pipeline()?;
-                if (!dry_run && snapshot.segments.len() > nodes_num) || enable_prune_pipeline  {
+                if (!dry_run && snapshot.segments.len() > nodes_num) || enable_prune_pipeline {
                     let mut segments = Vec::with_capacity(snapshot.segments.len());
                     for (idx, segment_location) in snapshot.segments.iter().enumerate() {
                         segments.push(FuseLazyPartInfo::create(idx, segment_location.clone()))

diff --git a/src/query/storages/fuse/src/pruning_pipeline/processor/send_partition_sink.rs b/src/query/storages/fuse/src/pruning_pipeline/processor/send_partition_sink.rs
@@ -28,7 +28,6 @@ use databend_common_pipeline_sinks::AsyncSink;
 use databend_common_pipeline_sinks::AsyncSinker;
 use databend_common_sql::field_default_value;
 use databend_common_storage::ColumnNodes;
-use log::info;
 
 use crate::pruning_pipeline::meta_info::BlockPruningResult;
 use crate::FuseTable;
@@ -72,7 +71,6 @@ impl AsyncSink for SendPartitionSink {
 
     #[async_backtrace::framed]
     async fn on_finish(&mut self) -> databend_common_exception::Result<()> {
-        info!("close SendPartitionSink {:?}", self.index);
         self.sender.close();
         Ok(())
     }