[ISSUE-160] [BUG] requestReserveSlot failed loss root cause (#161)

AngersZhuuuu · web-flow · commit 73b41ac8c5bc · 2022-06-23T16:33:41.000+08:00
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
@@ -1112,8 +1112,9 @@ class LifecycleManager(appId: String, val conf: RssConf) extends RpcEndpoint wit
       endpoint.askSync[ReserveSlotsResponse](message)
     } catch {
       case e: Exception =>
-        val msg = s"Exception when askSync ReserveSlots for $shuffleKey, ${e.getMessage}"
-        ReserveSlotsResponse(StatusCode.Failed, msg)
+        val msg = s"Exception when askSync ReserveSlots for $shuffleKey."
+        logError(msg, e)
+        ReserveSlotsResponse(StatusCode.Failed, msg + s" ${e.getMessage}")
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -1112,8 +1112,9 @@ class LifecycleManager(appId: String, val conf: RssConf) extends RpcEndpoint wit`
`1112`	`1112`	`endpoint.askSync[ReserveSlotsResponse](message)`
`1113`	`1113`	`} catch {`
`1114`	`1114`	`case e: Exception =>`
`1115`		`- val msg = s"Exception when askSync ReserveSlots for $shuffleKey, ${e.getMessage}"`
`1116`		`- ReserveSlotsResponse(StatusCode.Failed, msg)`
	`1115`	`+ val msg = s"Exception when askSync ReserveSlots for $shuffleKey."`
	`1116`	`+ logError(msg, e)`
	`1117`	`+ ReserveSlotsResponse(StatusCode.Failed, msg + s" ${e.getMessage}")`
`1117`	`1118`	`}`
`1118`	`1119`	`}`
`1119`	`1120`