apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CELEBORN-2127] When fileWriter is closed, it should return HARD_SPLIT StatusCode

Browse Source 
…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 <fengmingxiao.fmx@alibaba-inc.com>
This commit is contained in:
xxx 2025-09-03 16:04:32 +08:00 committed by mingji
parent 750aeefbc6
commit 449cb5d588
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
View File

@ -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
}