diff --git a/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.scala b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.scala index 9be9f50737..1007b0879f 100644 --- a/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.scala +++ b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.scala @@ -19,6 +19,7 @@ package org.apache.linkis.manager.rm.service.impl import com.google.common.collect.Lists import org.apache.linkis.common.ServiceInstance +import org.apache.linkis.common.exception.LinkisRetryException import org.apache.linkis.common.utils.{Logging, Utils} import org.apache.linkis.governance.common.conf.GovernanceCommonConf import org.apache.linkis.manager.common.conf.RMConfiguration @@ -590,7 +591,7 @@ class DefaultResourceManager extends ResourceManager with Logging with Initializ labelContainer.setCurrentLabel(label.asInstanceOf[Label[_]]) val locked = resourceLockService.tryLock(labelContainer, timeOut) if (!locked) { - throw new RMWarnException(110022, s"try to lock resource label ${labelContainer.getCurrentLabel} over $timeOut ms, please wait a moment and try again!") + throw new LinkisRetryException(110022, s"try to lock resource label ${labelContainer.getCurrentLabel} over $timeOut ms, please wait a moment and try again!") } case _ => }