diff --git a/src/query/storages/fuse/src/operations/read/block_partition_receiver_source.rs b/src/query/storages/fuse/src/operations/read/block_partition_receiver_source.rs
index e4ef936695bc..9922d1651c63 100644
--- a/src/query/storages/fuse/src/operations/read/block_partition_receiver_source.rs
+++ b/src/query/storages/fuse/src/operations/read/block_partition_receiver_source.rs
@@ -50,9 +50,9 @@ impl AsyncSource for BlockPartitionReceiverSource {
     #[async_backtrace::framed]
     async fn generate(&mut self) -> Result<Option<DataBlock>> {
         match self.meta_receiver.recv().await {
-            Ok(Ok(part)) => dbg!(Ok(Some(DataBlock::empty_with_meta(
+            Ok(Ok(part)) => Ok(Some(DataBlock::empty_with_meta(
                 BlockPartitionMeta::create(vec![part]),
-            )))),
+            ))),
             Ok(Err(e)) => Err(
                 // The error is occurred in pruning process
                 e,
diff --git a/src/query/storages/fuse/src/pruning_pipeline/send_part_info_sink.rs b/src/query/storages/fuse/src/pruning_pipeline/send_part_info_sink.rs
index ff1dbcbeea60..842da4dc8030 100644
--- a/src/query/storages/fuse/src/pruning_pipeline/send_part_info_sink.rs
+++ b/src/query/storages/fuse/src/pruning_pipeline/send_part_info_sink.rs
@@ -77,7 +77,7 @@ impl AsyncSink for SendPartInfoSink {
 
                 for info in info_ptr {
                     if let Some(sender) = &self.sender {
-                        let _ = dbg!(sender.send(Ok(info)).await);
+                        let _ = sender.send(Ok(info)).await;
                     }
                 }