You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ag...@apache.org on 2022/08/24 12:30:13 UTC
[arrow-ballista] branch master updated: use info instead print (#154)
This is an automated email from the ASF dual-hosted git repository.
agrove pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-ballista.git
The following commit(s) were added to refs/heads/master by this push:
new df9ce5e4 use info instead print (#154)
df9ce5e4 is described below
commit df9ce5e432c624bc89a0cf354205208c4c58816f
Author: Yang Jiang <ya...@ebay.com>
AuthorDate: Wed Aug 24 20:30:08 2022 +0800
use info instead print (#154)
---
ballista/rust/executor/src/metrics/mod.rs | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/ballista/rust/executor/src/metrics/mod.rs b/ballista/rust/executor/src/metrics/mod.rs
index 9a735c50..e4daaac1 100644
--- a/ballista/rust/executor/src/metrics/mod.rs
+++ b/ballista/rust/executor/src/metrics/mod.rs
@@ -17,6 +17,7 @@
use ballista_core::execution_plans::ShuffleWriterExec;
use datafusion::physical_plan::display::DisplayableExecutionPlan;
+use log::info;
use std::sync::Arc;
/// `ExecutorMetricsCollector` records metrics for `ShuffleWriteExec`
@@ -48,7 +49,7 @@ impl ExecutorMetricsCollector for LoggingMetricsCollector {
partition: usize,
plan: Arc<ShuffleWriterExec>,
) {
- println!(
+ info!(
"=== [{}/{}/{}] Physical plan with metrics ===\n{}\n",
job_id,
stage_id,