diff --git a/src/query/pipeline/core/src/processors/processor.rs b/src/query/pipeline/core/src/processors/processor.rs index 2fa5ed50244db..96a5e6866ac0d 100644 --- a/src/query/pipeline/core/src/processors/processor.rs +++ b/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, diff --git a/src/query/service/src/pipelines/executor/executor_graph.rs b/src/query/service/src/pipelines/executor/executor_graph.rs index 8df9495e78680..29d950a0b98b3 100644 --- a/src/query/service/src/pipelines/executor/executor_graph.rs +++ b/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 => { diff --git a/src/query/service/src/pipelines/executor/executor_worker_context.rs b/src/query/service/src/pipelines/executor/executor_worker_context.rs index 02dd713d13416..07270148a92ac 100644 --- a/src/query/service/src/pipelines/executor/executor_worker_context.rs +++ b/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> { - 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())) } diff --git a/src/query/service/src/pipelines/executor/processor_async_task.rs b/src/query/service/src/pipelines/executor/processor_async_task.rs index 21b98cc3f08fd..cbe5f2f6be556 100644 --- a/src/query/service/src/pipelines/executor/processor_async_task.rs +++ b/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; } }