From b1ce8060723eb8934b83b0e2489518a998de1ec7 Mon Sep 17 00:00:00 2001 From: v_wbxiongli <740332065@qq.com> Date: Sat, 16 Dec 2023 17:36:41 +0800 Subject: [PATCH] update download Signed-off-by: v_wbxiongli <740332065@qq.com> --- .../fedai/eggroll/clustermanager/job/JobServiceHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/jvm/cluster_manager/src/main/java/org/fedai/eggroll/clustermanager/job/JobServiceHandler.java b/jvm/cluster_manager/src/main/java/org/fedai/eggroll/clustermanager/job/JobServiceHandler.java index 356101d72..423855814 100644 --- a/jvm/cluster_manager/src/main/java/org/fedai/eggroll/clustermanager/job/JobServiceHandler.java +++ b/jvm/cluster_manager/src/main/java/org/fedai/eggroll/clustermanager/job/JobServiceHandler.java @@ -573,7 +573,8 @@ public PrepareJobDownloadResponse prepareJobDownload(Context context, PrepareJob for (SessionRanksTemp rank : sessionRanks) { sessionRankList.add(Arrays.asList(rank.getServerNodeId(),rank.getContainerId(),rank.getGlobalRank(),rank.getLocalRank(),rank.getIndex())); } - contentMap.put(serverNodeInDb.getServerNodeId().toString(), sessionRankList); + + contentMap.put(String.join(":",serverNodeInDb.getHost(),serverNodeInDb.getPort().toString()), sessionRankList); ErProcessor erProcessor = new ErProcessor(); erProcessor.setSessionId(sessionId); erProcessor.setServerNodeId(serverNodeId);