This is an automated email from the ASF dual-hosted git repository. peacewong pushed a commit to branch dev-1.1.1 in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit f1a950c84812665b7f641a5672939efa9b17132b Author: seedscoder <[email protected]> AuthorDate: Fri Apr 1 12:06:30 2022 +0800 fix(resource-manager): fix NullPointerException (#1850) --- .../org/apache/linkis/resourcemanager/message/RMMessageService.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/linkis-computation-governance/linkis-manager/linkis-resource-manager/src/main/scala/org/apache/linkis/resourcemanager/message/RMMessageService.scala b/linkis-computation-governance/linkis-manager/linkis-resource-manager/src/main/scala/org/apache/linkis/resourcemanager/message/RMMessageService.scala index f7fd95d..6ddcf1b 100644 --- a/linkis-computation-governance/linkis-manager/linkis-resource-manager/src/main/scala/org/apache/linkis/resourcemanager/message/RMMessageService.scala +++ b/linkis-computation-governance/linkis-manager/linkis-resource-manager/src/main/scala/org/apache/linkis/resourcemanager/message/RMMessageService.scala @@ -45,7 +45,8 @@ class RMMessageService extends Logging { Utils.tryCatch(resourceManager.resourceUsed(labels, resourceUsedProtocol.engineResource)) { case exception: Exception => { val nodeLabels = new RMLabelContainer(labels) - warn(s"usedResource failed, request from:${nodeLabels.getCombinedUserCreatorEngineTypeLabel.getStringValue}, request engine: ${nodeLabels.getEngineInstanceLabel}, " + + val value: String = Option(nodeLabels.getCombinedUserCreatorEngineTypeLabel).map(_.getStringValue).getOrElse("") + warn(s"usedResource failed, request from:$value, request engine: ${nodeLabels.getEngineInstanceLabel}, " + s"reason:${exception.getMessage}") throw exception } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
