This is an automated email from the ASF dual-hosted git repository.

milenkovicm 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 92277f71 chore: reduce log levels for few log statements (#1237)
92277f71 is described below

commit 92277f7170014820d010cd4d48e946f52b5d9a72
Author: Marko Milenković <[email protected]>
AuthorDate: Fri Apr 18 16:13:43 2025 +0100

    chore: reduce log levels for few log statements (#1237)
    
    I would argue they do not need to be printed as warnings.
---
 ballista/scheduler/src/state/execution_graph.rs | 4 ++--
 ballista/scheduler/src/state/mod.rs             | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/ballista/scheduler/src/state/execution_graph.rs 
b/ballista/scheduler/src/state/execution_graph.rs
index d937760d..9023a7ec 100644
--- a/ballista/scheduler/src/state/execution_graph.rs
+++ b/ballista/scheduler/src/state/execution_graph.rs
@@ -25,7 +25,7 @@ use std::time::{SystemTime, UNIX_EPOCH};
 use datafusion::physical_plan::display::DisplayableExecutionPlan;
 use datafusion::physical_plan::{accept, ExecutionPlan, ExecutionPlanVisitor};
 use datafusion::prelude::SessionConfig;
-use log::{error, info, warn};
+use log::{debug, error, info, warn};
 
 use ballista_core::error::{BallistaError, Result};
 use ballista_core::execution_plans::{ShuffleWriterExec, UnresolvedShuffleExec};
@@ -941,7 +941,7 @@ impl ExecutionGraph {
                 ..
             }
         ) {
-            warn!("Call fetch_runnable_stage on failed Job");
+            debug!("Call fetch_runnable_stage on failed Job");
             return None;
         }
 
diff --git a/ballista/scheduler/src/state/mod.rs 
b/ballista/scheduler/src/state/mod.rs
index c628aaf2..6d4f1e0e 100644
--- a/ballista/scheduler/src/state/mod.rs
+++ b/ballista/scheduler/src/state/mod.rs
@@ -167,7 +167,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static + 
AsExecutionPlan> SchedulerState<T,
             .bind_schedulable_tasks(self.task_manager.get_running_job_cache())
             .await?;
         if schedulable_tasks.is_empty() {
-            warn!("No schedulable tasks found to be launched");
+            debug!("No schedulable tasks found to be launched");
             return Ok(());
         }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to