You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafusion.apache.org by ag...@apache.org on 2025/01/16 00:12:59 UTC
(datafusion-ballista) branch main updated: chore: replace print statements from logs (#1162)
This is an automated email from the ASF dual-hosted git repository.
agrove pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new 9051983a chore: replace print statements from logs (#1162)
9051983a is described below
commit 9051983ae944175645e7e303f090f16da3a51e1b
Author: Marko Milenković <mi...@users.noreply.github.com>
AuthorDate: Thu Jan 16 00:12:55 2025 +0000
chore: replace print statements from logs (#1162)
---
ballista/core/src/consistent_hash/mod.rs | 1 -
ballista/core/src/diagram.rs | 3 ++-
ballista/scheduler/src/state/task_manager.rs | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/ballista/core/src/consistent_hash/mod.rs b/ballista/core/src/consistent_hash/mod.rs
index 98808ab3..6c159401 100644
--- a/ballista/core/src/consistent_hash/mod.rs
+++ b/ballista/core/src/consistent_hash/mod.rs
@@ -309,7 +309,6 @@ mod test {
let keys = vec!["1", "4", "5", "3", "2"];
for (i, key) in keys.iter().enumerate() {
- // println!("{}", consistent_hash.get(key.as_bytes()).unwrap().name());
assert_eq!(
consistent_hash.get(key.as_bytes()).unwrap().name(),
nodes[i].name()
diff --git a/ballista/core/src/diagram.rs b/ballista/core/src/diagram.rs
index 9ef0da98..40f1af1f 100644
--- a/ballista/core/src/diagram.rs
+++ b/ballista/core/src/diagram.rs
@@ -27,6 +27,7 @@ use datafusion::physical_plan::joins::HashJoinExec;
use datafusion::physical_plan::projection::ProjectionExec;
use datafusion::physical_plan::sorts::sort::SortExec;
use datafusion::physical_plan::ExecutionPlan;
+use log::warn;
use std::fs::File;
use std::io::{BufWriter, Write};
use std::sync::atomic::{AtomicUsize, Ordering};
@@ -110,7 +111,7 @@ fn build_exec_plan_diagram(
{
"CoalescePartitionsExec"
} else {
- println!("Unknown: {plan:?}");
+ warn!("Unknown: {plan:?}");
"Unknown"
};
diff --git a/ballista/scheduler/src/state/task_manager.rs b/ballista/scheduler/src/state/task_manager.rs
index cc8442f2..8bad64f6 100644
--- a/ballista/scheduler/src/state/task_manager.rs
+++ b/ballista/scheduler/src/state/task_manager.rs
@@ -422,7 +422,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan> TaskManager<T, U>
graph.revive();
- println!("Saving job with status {:?}", graph.status());
+ info!("Saving job with status {:?}", graph.status());
self.state.save_job(job_id, &graph).await?;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org