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 249d0e11 Fixes Setting Job Name Not Reflected in Ballista UI (#1039)
249d0e11 is described below
commit 249d0e114fcabb4048f628c31822f7250c574061
Author: Athul T R <[email protected]>
AuthorDate: Sat Jul 13 19:43:19 2024 +0530
Fixes Setting Job Name Not Reflected in Ballista UI (#1039)
* Fixes the issue of job name not being displayed in the Ballista UI after
being set.
Fixes: #1019
Authored-by: athultr1997 ([email protected])
---
ballista/core/src/execution_plans/distributed_query.rs | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
diff --git a/ballista/core/src/execution_plans/distributed_query.rs
b/ballista/core/src/execution_plans/distributed_query.rs
index 2f12a674..4e7a1c2b 100644
--- a/ballista/core/src/execution_plans/distributed_query.rs
+++ b/ballista/core/src/execution_plans/distributed_query.rs
@@ -21,7 +21,7 @@ use
crate::serde::protobuf::execute_query_params::OptionalSessionId;
use crate::serde::protobuf::{
execute_query_params::Query, execute_query_result, job_status,
scheduler_grpc_client::SchedulerGrpcClient, ExecuteQueryParams,
GetJobStatusParams,
- GetJobStatusResult, PartitionLocation,
+ GetJobStatusResult, KeyValuePair, PartitionLocation,
};
use crate::utils::create_grpc_client_connection;
use datafusion::arrow::datatypes::SchemaRef;
@@ -208,7 +208,15 @@ impl<T: 'static + AsLogicalPlan> ExecutionPlan for
DistributedQueryExec<T> {
let query = ExecuteQueryParams {
query: Some(Query::LogicalPlan(buf)),
- settings: vec![],
+ settings: self
+ .config
+ .settings()
+ .iter()
+ .map(|(k, v)| KeyValuePair {
+ key: k.to_owned(),
+ value: v.to_owned(),
+ })
+ .collect::<Vec<_>>(),
optional_session_id: Some(OptionalSessionId::SessionId(
self.session_id.clone(),
)),
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
