add to async ReadParquetDataSource

databendlabs · Nov 30, 2023 · 45edbc1 · 45edbc1
1 parent 271e9fb
commit 45edbc1
Showing 1 changed file with 0 additions and 2 deletions.
diff --git 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);