bugfix refresh maxAllowRunningJobs

apache · Nov 19, 2023 · 9f4a9c8 · 9f4a9c8
1 parent 5a5e5b3
commit 9f4a9c8
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/...ons/linkis-common/src/main/scala/org/apache/linkis/common/utils/CodeAndRunTypeUtils.scala b/...ons/linkis-common/src/main/scala/org/apache/linkis/common/utils/CodeAndRunTypeUtils.scala
@@ -18,6 +18,7 @@
 package org.apache.linkis.common.utils
 
 import org.apache.linkis.common.conf.CommonVars
+
 import org.apache.commons.lang3.StringUtils
 
 import scala.collection.mutable

diff --git a/...src/main/scala/org/apache/linkis/entrance/scheduler/EntranceParallelConsumerManager.scala b/...src/main/scala/org/apache/linkis/entrance/scheduler/EntranceParallelConsumerManager.scala
@@ -77,7 +77,6 @@ class EntranceParallelConsumerManager(maxParallelismUsers: Int, schedulerName: S
   }
 
   def refreshAllGroupMaxAllowRunningJobs(validInsCount: Int): Unit = {
-    if (validInsCount <= 1) return
     listConsumers()
       .foreach(item => {
         item.getGroup match {