You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by zh...@apache.org on 2022/11/22 10:29:19 UTC
[incubator-celeborn] branch main updated: [CELEBORN-42][BUG] PushMergedData use wrong call back when partition not found (#991)
This is an automated email from the ASF dual-hosted git repository.
zhouky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
The following commit(s) were added to refs/heads/main by this push:
new e12000cb [CELEBORN-42][BUG] PushMergedData use wrong call back when partition not found (#991)
e12000cb is described below
commit e12000cb6764c013e3dab06818a22247e8733d4f
Author: Angerszhuuuu <an...@gmail.com>
AuthorDate: Tue Nov 22 18:29:15 2022 +0800
[CELEBORN-42][BUG] PushMergedData use wrong call back when partition not found (#991)
---
.../org/apache/celeborn/service/deploy/worker/PushDataHandler.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
index 02dd6a71..9d7f2316 100644
--- a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
+++ b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
@@ -322,7 +322,7 @@ class PushDataHandler extends BaseMessageHandler with Logging {
val msg = s"Partition location wasn't found for task(shuffle $shuffleKey, map $mapId," +
s" attempt $attemptId, uniqueId $id)."
logWarning(s"[handlePushMergedData] $msg")
- wrappedCallback.onFailure(new Exception(msg))
+ callback.onFailure(new Exception(msg))
}
return
}