From 6a1e7d3f8cb19c08d9c9bb85a3150e7fbc2d1cef Mon Sep 17 00:00:00 2001 From: zhengtao Date: Mon, 16 Dec 2024 15:06:14 +0800 Subject: [PATCH] typo --- .../apache/celeborn/service/deploy/worker/PushDataHandler.scala | 1 - 1 file changed, 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 dad7a651f79..8cc03500932 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 @@ -619,7 +619,6 @@ class PushDataHandler(val workerSource: WorkerSource) extends BaseMessageHandler } } handlePushMergedDataConnectionFail(pushMergedDataCallback, location) - callbackWithTimer.onFailure(new CelebornIOException(StatusCode.PUSH_DATA_CREATE_CONNECTION_FAIL_REPLICA)) return } pushMergedData.body().retain()