From 635643ff2e1321b46c825d4764f1d87cc0bd7fd8 Mon Sep 17 00:00:00 2001 From: aiceflower Date: Tue, 17 Dec 2024 18:49:40 +0800 Subject: [PATCH] code optimization --- .../scala/org/apache/linkis/entrance/EntranceServer.scala | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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