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

[ISSUE-534][REFACTOR] Refactor log when call handleGetReducerFileGroup (#535)

Browse Source
This commit is contained in:
AngersZhuuuu 2022-09-05 19:48:57 +08:00 committed by GitHub
parent 82566148d8
commit f7211204f2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client/src/main/scala/com/aliyun/emr/rss/client/write/LifecycleManager.scala
View File

@ -637,14 +637,14 @@ class LifecycleManager(appId: String, val conf: RssConf) extends RpcEndpoint wit
while (!stageEndShuffleSet.contains(shuffleId)) {
Thread.sleep(delta)
if (timeout <= 0) {
logError(s"StageEnd Timeout! $shuffleId.")
logError(s"[handleGetReducerFileGroup] Wait for handleStageEnd Timeout! $shuffleId.")
context.reply(
GetReducerFileGroupResponse(StatusCode.StageEndTimeOut, Array.empty, Array.empty))
return
}
timeout = timeout - delta
}
logInfo("[handleGetReducerFileGroup] Wait for handleStageEnd complete cost" +
logDebug("[handleGetReducerFileGroup] Wait for handleStageEnd complete cost" +
s" ${stageEndTimeout - timeout}ms")
if (dataLostShuffleSet.contains(shuffleId)) {