diff --git a/client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java b/client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java index 129dadc173..7912e098df 100644 --- a/client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java +++ b/client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java @@ -944,6 +944,7 @@ public void close() { @Override public void unregisterShuffle(String appId, int shuffleId) { + int unregisterTimeMs = unregisterRequestTimeSec * 1000; RssUnregisterShuffleRequest request = new RssUnregisterShuffleRequest(appId, shuffleId); Map> appServerMap = shuffleServerInfoMap.get(appId); @@ -978,7 +979,7 @@ public void unregisterShuffle(String appId, int shuffleId) { } return null; }, - unregisterRequestTimeSec, + unregisterTimeMs, "unregister shuffle server"); } finally { @@ -991,6 +992,7 @@ public void unregisterShuffle(String appId, int shuffleId) { @Override public void unregisterShuffle(String appId) { + int unregisterTimeMs = unregisterRequestTimeSec * 1000; RssUnregisterShuffleByAppIdRequest request = new RssUnregisterShuffleByAppIdRequest(appId); if (appId == null) { @@ -1026,7 +1028,7 @@ public void unregisterShuffle(String appId) { } return null; }, - unregisterRequestTimeSec, + unregisterTimeMs, "unregister shuffle server"); } finally {