Skip to content

Commit

Permalink
chore(executor): remove useless warn log (#14672)
Browse files Browse the repository at this point in the history
* chore(executor): remove useless warn log

* chore(executor): remove useless warn log
  • Loading branch information
zhang2014 authored Feb 18, 2024
1 parent efa0e46 commit 0870ccc
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ use databend_common_pipeline_core::processors::Processor;
use databend_common_pipeline_core::Pipeline;
use databend_common_pipeline_sinks::Sink;
use databend_common_pipeline_sinks::Sinker;
use log::warn;
use minitrace::full_name;
use minitrace::prelude::*;
use parking_lot::Condvar;
Expand Down Expand Up @@ -215,8 +214,6 @@ impl PipelinePullingExecutor {
continue;
}
Err(RecvTimeoutError::Disconnected) => {
warn!("receiver has been disconnected, finish executor now");

if !self.executor.is_finished() {
self.executor.finish(None);
}
Expand Down

0 comments on commit 0870ccc

Please sign in to comment.