From dcaa1cff0e1fcb8dda211ae19d1fe24ee9cc2708 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=9E=97=E4=BC=9F?= <lewiszlw520@gmail.com>
Date: Thu, 13 Jun 2024 00:28:37 +0800
Subject: [PATCH] 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 25bb8e754..58e56d9e9 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