From 9ae5bba7cf571d251a05966d3ea5aaf6b568d20b Mon Sep 17 00:00:00 2001
From: fangfengbin <869218239a@zju.edu.cn>
Date: Thu, 7 Jan 2021 10:37:00 +0800
Subject: [PATCH] [GCS]Fix gcs table storage `GetAll` and `GetByJobId` api bug
 (#13195)

---
 src/ray/gcs/gcs_server/gcs_table_storage.cc | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git a/src/ray/gcs/gcs_server/gcs_table_storage.cc b/src/ray/gcs/gcs_server/gcs_table_storage.cc
index 5eea83484..324255908 100644
--- a/src/ray/gcs/gcs_server/gcs_table_storage.cc
+++ b/src/ray/gcs/gcs_server/gcs_table_storage.cc
@@ -49,9 +49,11 @@ Status GcsTable<Key, Data>::GetAll(const MapCallback<Key, Data> &callback) {
   auto on_done = [callback](const std::unordered_map<std::string, std::string> &result) {
     std::unordered_map<Key, Data> values;
     for (auto &item : result) {
-      Data data;
-      data.ParseFromString(item.second);
-      values[Key::FromBinary(item.first)] = data;
+      if (!item.second.empty()) {
+        Data data;
+        data.ParseFromString(item.second);
+        values[Key::FromBinary(item.first)] = data;
+      }
     }
     callback(values);
   };
@@ -89,9 +91,11 @@ Status GcsTableWithJobId<Key, Data>::GetByJobId(const JobID &job_id,
   auto on_done = [callback](const std::unordered_map<std::string, std::string> &result) {
     std::unordered_map<Key, Data> values;
     for (auto &item : result) {
-      Data data;
-      data.ParseFromString(item.second);
-      values[Key::FromBinary(item.first)] = std::move(data);
+      if (!item.second.empty()) {
+        Data data;
+        data.ParseFromString(item.second);
+        values[Key::FromBinary(item.first)] = std::move(data);
+      }
     }
     callback(values);
   };