From 83870066ad0cb2fbb516a1dba18b92cc864e1523 Mon Sep 17 00:00:00 2001 From: e <1178404354@qq.com> Date: Mon, 24 Jul 2023 17:50:17 +0800 Subject: [PATCH] [CELEBORN-833] Remove unused attributes and declaration of thrown exception 'java.io.IOException' --- .../src/main/java/org/apache/celeborn/client/ReviveManager.java | 1 - .../main/java/org/apache/celeborn/client/ShuffleClientImpl.java | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/client/src/main/java/org/apache/celeborn/client/ReviveManager.java b/client/src/main/java/org/apache/celeborn/client/ReviveManager.java index c764351a5e3..7f8082a73ad 100644 --- a/client/src/main/java/org/apache/celeborn/client/ReviveManager.java +++ b/client/src/main/java/org/apache/celeborn/client/ReviveManager.java @@ -79,7 +79,6 @@ public ReviveManager(ShuffleClientImpl shuffleClient, CelebornConf conf) { } else { filteredRequests.add(req); mapIds.add(req.mapId); - PartitionLocation loc = req.loc; if (!requestsToSend.containsKey(req.partitionId) || requestsToSend.get(req.partitionId).epoch < req.epoch) { requestsToSend.put(req.partitionId, req); diff --git a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java index 19e03c63fd6..9a5927fbfea 100644 --- a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java +++ b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java @@ -1570,7 +1570,7 @@ protected ReduceFileGroups loadFileGroupInternal(int shuffleId) { } } - protected ReduceFileGroups updateFileGroup(int shuffleId, int partitionId) throws IOException { + protected ReduceFileGroups updateFileGroup(int shuffleId) { return reduceFileGroupsMap.computeIfAbsent(shuffleId, (id) -> loadFileGroupInternal(shuffleId)); }