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);