wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-19 11:27:32 +08:00
Code Issues Packages Projects Releases Wiki Activity

[GCS]Fix gcs table storage GetAll and GetByJobId api bug (#13195)

Browse Source
This commit is contained in:
fangfengbin
2021-01-07 10:37:00 +08:00
committed by GitHub
parent dde49b8d48
commit 9ae5bba7cf
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/gcs/gcs_server/gcs_table_storage.cc
+10 -6
View File
@@ -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);
};