typo

apache · Dec 16, 2024 · 6a1e7d3 · 6a1e7d3
1 parent 82aadda
commit 6a1e7d3
Showing 1 changed file with 0 additions and 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
@@ -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()