update retry exception

WeDataSphere · Jul 19, 2022 · 72c1f6f · 72c1f6f
1 parent 43af5ba
commit 72c1f6f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ger/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.scala b/...ger/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 _ =>
     }