chore(pipeline): rm log for processor event.
@@ -241,15 +241,7 @@ impl ExecutingGraph {
if state_guard_cache.is_none() {
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 => {
