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 f7e5bd10 minor: change log level (#1340)
f7e5bd10 is described below
commit f7e5bd10facd5aac3bc2058aa61bf34a586556ba
Author: Marko Milenković <[email protected]>
AuthorDate: Mon Nov 3 17:19:30 2025 +0000
minor: change log level (#1340)
---
ballista/executor/src/cpu_bound_executor.rs | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/ballista/executor/src/cpu_bound_executor.rs
b/ballista/executor/src/cpu_bound_executor.rs
index 83e2c1cd..a3c9e8f5 100644
--- a/ballista/executor/src/cpu_bound_executor.rs
+++ b/ballista/executor/src/cpu_bound_executor.rs
@@ -20,7 +20,7 @@
//! This module contains a dedicated thread pool for running "cpu
//! intensive" workloads as query plans
-use log::warn;
+use log::{debug, warn};
use parking_lot::Mutex;
use std::{pin::Pin, sync::Arc};
use tokio::sync::oneshot::Receiver;
@@ -146,7 +146,7 @@ impl DedicatedExecutor {
let job = Box::pin(async move {
let task_output = task.await;
if tx.send(task_output).is_err() {
- warn!("Spawned task output ignored: receiver dropped");
+ debug!("Spawned task output ignored: receiver dropped");
}
});
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
