diff --git a/java/runtime/src/main/java/org/ray/runtime/gcs/GcsClient.java b/java/runtime/src/main/java/org/ray/runtime/gcs/GcsClient.java index c5f849a75144..d1050cbd9748 100644 --- a/java/runtime/src/main/java/org/ray/runtime/gcs/GcsClient.java +++ b/java/runtime/src/main/java/org/ray/runtime/gcs/GcsClient.java @@ -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; @@ -76,12 +75,12 @@ public List getAllNodeInfo() { 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); } }