diff --git a/ballista/rust/scheduler/src/state/stage_manager.rs b/ballista/rust/scheduler/src/state/stage_manager.rs
index f83b5fda9cae..b15978436768 100644
--- a/ballista/rust/scheduler/src/state/stage_manager.rs
+++ b/ballista/rust/scheduler/src/state/stage_manager.rs
@@ -18,7 +18,7 @@
 use std::collections::{HashMap, HashSet};
 use std::sync::Arc;
 
-use log::{error, info, warn};
+use log::{debug, error, warn};
 use parking_lot::RwLock;
 use rand::Rng;
 
@@ -305,7 +305,7 @@ impl StageScheduler for StageManager {
         let stage_distribution = self.stage_distribution.read();
         let stages_running = &stage_distribution.stages_running;
         if stages_running.is_empty() {
-            info!("There's no running stages");
+            debug!("There's no running stages");
             return None;
         }
         let stages = stages_running
diff --git a/ballista/rust/scheduler/src/state/task_scheduler.rs b/ballista/rust/scheduler/src/state/task_scheduler.rs
index 3ebd033d4995..1ae66b1b248b 100644
--- a/ballista/rust/scheduler/src/state/task_scheduler.rs
+++ b/ballista/rust/scheduler/src/state/task_scheduler.rs
@@ -182,7 +182,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan> TaskScheduler
         }
 
         let total_task_num = tasks_status.len();
-        info!("{} tasks to be scheduled", total_task_num);
+        debug!("{} tasks to be scheduled", total_task_num);
 
         // No need to deal with the stage event, since the task status is changing from pending to running
         self.stage_manager.update_tasks_status(tasks_status);