code optimization

WeDataSphere · Dec 20, 2024 · b9283d1 · b9283d1
1 parent 8b6fd5e
commit b9283d1
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/EntranceServer.scala b/...governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/EntranceServer.scala
@@ -178,7 +178,10 @@ abstract class EntranceServer extends Logging {
 
       Utils.tryAndWarn {
         // 如果是使用优先级队列，设置下优先级
-        val properties: util.Map[String, AnyRef] = TaskUtils.getRuntimeMap(params)
+        val configMap = params
+          .getOrDefault(TaskConstant.PARAMS, new util.HashMap[String, AnyRef]())
+          .asInstanceOf[util.Map[String, AnyRef]]
+        val properties: util.Map[String, AnyRef] = TaskUtils.getRuntimeMap(configMap)
         val fifoStrategy: String = FIFO_QUEUE_STRATEGY
         if (
             PFIFO_SCHEDULER_STRATEGY.equalsIgnoreCase(