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,