From 45edbc1a2a000081b4c4afe6e489e11f6d09ae61 Mon Sep 17 00:00:00 2001
From: xudong963 <wxd963996380@gmail.com>
Date: Thu, 30 Nov 2023 15:54:25 +0800
Subject: [PATCH] add to async ReadParquetDataSource

---
 src/query/service/src/pipelines/executor/executor_graph.rs | 2 --
 1 file changed, 2 deletions(-)

diff --git a/src/query/service/src/pipelines/executor/executor_graph.rs b/src/query/service/src/pipelines/executor/executor_graph.rs
index 7a69672907fce..a13dbc9dbe13d 100644
--- a/src/query/service/src/pipelines/executor/executor_graph.rs
+++ b/src/query/service/src/pipelines/executor/executor_graph.rs
@@ -341,7 +341,6 @@ impl ExecutingGraph {
     ) -> Result<()> {
         if neighbors.clone().next().is_none() {
             // Source node
-            dbg!("find source node");
             let source_node = locker.graph[current_node].clone();
             source_node
                 .processor
@@ -350,7 +349,6 @@ impl ExecutingGraph {
         }
         for neighbor in neighbors {
             let current_node = locker.graph[neighbor].clone();
-            dbg!(&current_node.processor.name());
             let nodes = locker
                 .graph
                 .neighbors_directed(neighbor, Direction::Incoming);