We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b28877e commit f2a9107Copy full SHA for f2a9107
src/query/service/src/pipelines/processors/transforms/broadcast.rs
@@ -50,14 +50,7 @@ impl AsyncSource for BroadcastSourceProcessor {
50
51
#[async_backtrace::framed]
52
async fn generate(&mut self) -> Result<Option<DataBlock>> {
53
- let start = std::time::Instant::now();
54
- log::info!("BroadcastSource recv() start");
55
let received = self.receiver.recv().await;
56
- log::info!(
57
- "BroadcastSource recv() take {:?}, received: {:?}",
58
- start.elapsed(),
59
- received
60
- );
61
match received {
62
Ok(meta) => Ok(Some(DataBlock::empty_with_meta(meta))),
63
Err(_) => {
0 commit comments