Merge pull request #7752 from datafuselabs/revert-7486-log2

refactor(executor): reverts #7486

Author: mergify[bot]

src/query/pipeline/core/src/processors/processor.rs

@@ -23,7 +23,6 @@ use futures::FutureExt;
 use petgraph::graph::node_index;
 use petgraph::prelude::NodeIndex;
 
-#[derive(Debug)]
 pub enum Event {
     NeedData,
     NeedConsume,

src/query/service/src/pipelines/executor/executor_graph.rs

@@ -242,15 +242,7 @@ impl ExecutingGraph {
                     state_guard_cache = Some(node.state.lock().unwrap());
                 }
 
-                let event = node.processor.event()?;
-                tracing::debug!(
-                    "node id:{:?}, name:{:?}, event: {:?}",
-                    node.processor.id(),
-                    node.processor.name(),
-                    event
-                );
-
-                let processor_state = match event {
+                let processor_state = match node.processor.event()? {
                     Event::Finished => State::Finished,
                     Event::NeedData | Event::NeedConsume => State::Idle,
                     Event::Sync => {

src/query/service/src/pipelines/executor/executor_worker_context.rs

@@ -15,7 +15,6 @@
 use std::fmt::Debug;
 use std::fmt::Formatter;
 use std::sync::Arc;
-use std::time::Instant;
 
 use common_base::base::TrySpawn;
 use common_exception::ErrorCode;
@@ -80,19 +79,7 @@ impl ExecutorWorkerContext {
     }
 
     unsafe fn execute_sync_task(&mut self, processor: ProcessorPtr) -> Result<Option<NodeIndex>> {
-        if tracing::enabled!(tracing::Level::DEBUG) {
-            let start = Instant::now();
-            processor.process()?;
-            tracing::debug!(
-                "sync processor, node id:{:?}, name:{:?}, event: {:?}",
-                processor.id(),
-                processor.name(),
-                start.elapsed()
-            );
-        } else {
-            processor.process()?;
-        }
-
+        processor.process()?;
         Ok(Some(processor.id()))
     }
 

src/query/service/src/pipelines/executor/processor_async_task.rs

@@ -80,12 +80,6 @@ impl ProcessorAsyncTask {
                             );
                         }
                         Either::Right((res, _)) => {
-                            tracing::debug!(
-                                "async processor, node id {:?} name: {:?}, elapsed:{:?}",
-                                wraning_processor.id(),
-                                wraning_processor.name(),
-                                start.elapsed()
-                            );
                             return res;
                         }
                     }