diff --git a/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/EntranceServer.scala b/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/EntranceServer.scala index 06afdac3b3..04ede15574 100644 --- a/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/EntranceServer.scala +++ b/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/EntranceServer.scala @@ -35,7 +35,7 @@ import org.apache.linkis.governance.common.utils.LoggerUtils import org.apache.linkis.protocol.constants.TaskConstant import org.apache.linkis.protocol.utils.TaskUtils import org.apache.linkis.rpc.Sender -import org.apache.linkis.scheduler.conf.SchedulerConfiguration.{ENGINE_PRIORITY_RUNTIME_KEY, FIFO_QUEUE_STRATEGY} +import org.apache.linkis.scheduler.conf.SchedulerConfiguration.{ENGINE_PRIORITY_RUNTIME_KEY, FIFO_QUEUE_STRATEGY, PFIFO_SCHEDULER_STRATEGY} import org.apache.linkis.scheduler.queue.{Job, SchedulerEventState} import org.apache.linkis.server.conf.ServerConfiguration @@ -174,9 +174,8 @@ abstract class EntranceServer extends Logging { Utils.tryAndWarn{ // 如果是使用优先级队列,设置下优先级 val properties: util.Map[String, AnyRef] = TaskUtils.getRuntimeMap(params) - val PFIFO = "pfifo" val fifoStrategy: String = FIFO_QUEUE_STRATEGY - if (PFIFO.equalsIgnoreCase(fifoStrategy) && properties != null && !properties.isEmpty) { + if (PFIFO_SCHEDULER_STRATEGY.equalsIgnoreCase(fifoStrategy) && properties != null && !properties.isEmpty) { val priorityValue: AnyRef = properties.get(ENGINE_PRIORITY_RUNTIME_KEY) if (priorityValue != null) { val value: Int = priorityValue.toString.toInt