We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent efa0e46 commit 0870cccCopy full SHA for 0870ccc
src/query/service/src/pipelines/executor/pipeline_pulling_executor.rs
@@ -28,7 +28,6 @@ use databend_common_pipeline_core::processors::Processor;
28
use databend_common_pipeline_core::Pipeline;
29
use databend_common_pipeline_sinks::Sink;
30
use databend_common_pipeline_sinks::Sinker;
31
-use log::warn;
32
use minitrace::full_name;
33
use minitrace::prelude::*;
34
use parking_lot::Condvar;
@@ -215,8 +214,6 @@ impl PipelinePullingExecutor {
215
214
continue;
216
}
217
Err(RecvTimeoutError::Disconnected) => {
218
- warn!("receiver has been disconnected, finish executor now");
219
-
220
if !self.executor.is_finished() {
221
self.executor.finish(None);
222
0 commit comments