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 dcaa1cff Fix executor metadata decode bug (#1004)
dcaa1cff is described below
commit dcaa1cff0e1fcb8dda211ae19d1fe24ee9cc2708
Author: 张林伟 <[email protected]>
AuthorDate: Thu Jun 13 00:28:37 2024 +0800
Fix executor metadata decode bug (#1004)
---
ballista/scheduler/src/cluster/kv.rs | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/ballista/scheduler/src/cluster/kv.rs
b/ballista/scheduler/src/cluster/kv.rs
index 25bb8e75..58e56d9e 100644
--- a/ballista/scheduler/src/cluster/kv.rs
+++ b/ballista/scheduler/src/cluster/kv.rs
@@ -429,6 +429,12 @@ impl<S: KeyValueStore, T: 'static + AsLogicalPlan, U:
'static + AsExecutionPlan>
metadata.value().clone()
} else {
let value = self.store.get(Keyspace::Executors,
executor_id).await?;
+ if value.is_empty() {
+ return Err(BallistaError::Internal(format!(
+ "Executor {} not registered",
+ executor_id
+ )));
+ }
let decoded =
decode_into::<protobuf::ExecutorMetadata,
ExecutorMetadata>(&value)?;
self.executors
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
