From f7211204f273db61410de9bb0dde5beed2bbdb78 Mon Sep 17 00:00:00 2001 From: AngersZhuuuu Date: Mon, 5 Sep 2022 19:48:57 +0800 Subject: [PATCH] [ISSUE-534][REFACTOR] Refactor log when call `handleGetReducerFileGroup ` (#535) --- .../com/aliyun/emr/rss/client/write/LifecycleManager.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/client/src/main/scala/com/aliyun/emr/rss/client/write/LifecycleManager.scala b/client/src/main/scala/com/aliyun/emr/rss/client/write/LifecycleManager.scala index d492f766f..83c4af9f3 100644 --- a/client/src/main/scala/com/aliyun/emr/rss/client/write/LifecycleManager.scala +++ b/client/src/main/scala/com/aliyun/emr/rss/client/write/LifecycleManager.scala @@ -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)) {