fix compile error

kwai · Sep 14, 2024 · eca3c6e · eca3c6e
1 parent a0d4b20
commit eca3c6e
Show file tree

Hide file tree

Showing 2 changed files with 39 additions and 15 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/native-engine/datafusion-ext-plans/src/orc_exec.rs b/native-engine/datafusion-ext-plans/src/orc_exec.rs
@@ -177,9 +177,10 @@ impl ExecutionPlan for OrcExec {
                     "OrcScan",
                     stream.schema(),
                     move |sender| async move {
-                        let mut timer = baseline_metrics_cloned.elapsed_compute().timer();
+                        sender.exclude_time(baseline_metrics_cloned.elapsed_compute());
+                        let _timer = baseline_metrics_cloned.elapsed_compute().timer();
                         while let Some(batch) = stream.next().await.transpose()? {
-                            sender.send(Ok(batch), Some(&mut timer)).await;
+                            sender.send(Ok(batch)).await;
                         }
                         Ok(())
                     },