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::GetAll(const MapCallback &callback) { auto on_done = [callback](const std::unordered_map &result) { std::unordered_map 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::GetByJobId(const JobID &job_id, auto on_done = [callback](const std::unordered_map &result) { std::unordered_map 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); };