From 9f4a9c881d17ccf8d125155803eb79e7f1299349 Mon Sep 17 00:00:00 2001 From: guoshupei <15764973965@163.com> Date: Sun, 19 Nov 2023 15:48:22 +0800 Subject: [PATCH] bugfix `refresh maxAllowRunningJobs` --- .../org/apache/linkis/common/utils/CodeAndRunTypeUtils.scala | 1 + .../entrance/scheduler/EntranceParallelConsumerManager.scala | 1 - 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/utils/CodeAndRunTypeUtils.scala b/linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/utils/CodeAndRunTypeUtils.scala index cf40f9a349..917ac53261 100644 --- a/linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/utils/CodeAndRunTypeUtils.scala +++ b/linkis-commons/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/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/scheduler/EntranceParallelConsumerManager.scala b/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/scheduler/EntranceParallelConsumerManager.scala index 0f86c2a335..2cdee97cc7 100644 --- a/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/scheduler/EntranceParallelConsumerManager.scala +++ b/linkis-computation-governance/linkis-entrance/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 {