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 5541b8b4 fix issues-1235 (#1236)
5541b8b4 is described below
commit 5541b8b44b390ee25c421e9ee42f364fbf3a7156
Author: Mo Yi <[email protected]>
AuthorDate: Sat Apr 12 21:06:55 2025 +0800
fix issues-1235 (#1236)
---
ballista/scheduler/src/state/task_manager.rs | 4 ++--
examples/src/object_store.rs | 1 +
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/ballista/scheduler/src/state/task_manager.rs
b/ballista/scheduler/src/state/task_manager.rs
index b3e6e064..c267aa71 100644
--- a/ballista/scheduler/src/state/task_manager.rs
+++ b/ballista/scheduler/src/state/task_manager.rs
@@ -593,7 +593,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static +
AsExecutionPlan> TaskManager<T, U>
.as_millis() as u64;
let mut multi_tasks = vec![];
-
+ let props = task.session_config.to_key_value_pairs();
let task_ids = tasks
.into_iter()
.map(|task| TaskId {
@@ -610,7 +610,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static +
AsExecutionPlan> TaskManager<T, U>
plan,
session_id,
launch_time,
- props: vec![],
+ props,
});
Ok(multi_tasks)
diff --git a/examples/src/object_store.rs b/examples/src/object_store.rs
index 0b2b9e15..c596a3da 100644
--- a/examples/src/object_store.rs
+++ b/examples/src/object_store.rs
@@ -94,6 +94,7 @@ pub fn custom_session_state_with_s3_support(
Ok(SessionStateBuilder::new()
.with_runtime_env(runtime_env)
.with_config(session_config)
+ .with_default_features()
.build())
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
