Skip to content

Commit

Permalink
[CELEBORN-833] Remove unused attributes and declaration of thrown exc…
Browse files Browse the repository at this point in the history
…eption 'java.io.IOException'
  • Loading branch information
jiaoqingbo committed Jul 24, 2023
1 parent 070d8bc commit 8387006
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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));
}

Expand Down

0 comments on commit 8387006

Please sign in to comment.