From 449cb5d5882d2947052ea2b3ed36e3351328c18b Mon Sep 17 00:00:00 2001 From: xxx <953396112@qq.com> Date: Wed, 3 Sep 2025 16:04:32 +0800 Subject: [PATCH] [CELEBORN-2127] When fileWriter is closed, it should return HARD_SPLIT StatusCode MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit …T StatusCode ### What changes were proposed in this pull request? When fileWriter is closed, it should return HARD_SPLIT StatusCode ### Why are the changes needed? When fileWriter is closed, it should return HARD_SPLIT StatusCode ### Does this PR introduce _any_ user-facing change? NO ### How was this patch tested? CI Closes #3448 from xy2953396112/CELEBORN-2127. Authored-by: xxx <953396112@qq.com> Signed-off-by: mingji --- .../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 3e526a71e..8275958e2 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 @@ -265,7 +265,7 @@ class PushDataHandler(val workerSource: WorkerSource) extends BaseMessageHandler logWarning( s"[handlePushData] FileWriter is already closed! File path ${fileInfo.getFilePath} " + s"length ${fileInfo.getFileLength}") - callbackWithTimer.onFailure(new CelebornIOException("File already closed!")) + callbackWithTimer.onSuccess(ByteBuffer.wrap(Array[Byte](StatusCode.HARD_SPLIT.getValue))) fileWriter.decrementPendingWrites() return }