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

Fix GcsClient resource map (#5171)

Browse Source
This commit is contained in:
Kai Yang
2019-07-11 16:05:12 +08:00
committed by Hao Chen
parent f2293243cc
commit d8b50a5018
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/runtime/src/main/java/org/ray/runtime/gcs/GcsClient.java
+2 -3
View File
@@ -1,7 +1,6 @@
package org.ray.runtime.gcs;
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableMap;
import com.google.protobuf.InvalidProtocolBufferException;
import java.util.ArrayList;
import java.util.HashMap;
@@ -77,12 +76,12 @@ public class GcsClient {
if (data.getIsInsertion()) {
//Code path of node insertion.
NodeInfo nodeInfo = new NodeInfo(
clientId, data.getNodeManagerAddress(), true, ImmutableMap.of());
clientId, data.getNodeManagerAddress(), true, new HashMap<>());
clients.put(clientId, nodeInfo);
} else {
// Code path of node deletion.
NodeInfo nodeInfo = new NodeInfo(clientId, clients.get(clientId).nodeAddress,
false, ImmutableMap.of());
false, new HashMap<>());
clients.put(clientId, nodeInfo);
}
}