dss-server:fix code

WeDataSphere · Oct 18, 2024 · eaa421e · eaa421e
1 parent 0dca829
commit eaa421e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/...nk/wedatasphere/dss/flow/execution/entrance/conf/FlowExecutionEntranceConfiguration.scala b/...nk/wedatasphere/dss/flow/execution/entrance/conf/FlowExecutionEntranceConfiguration.scala
@@ -71,8 +71,10 @@ object FlowExecutionEntranceConfiguration {
 
   val FLOW_RESOURCES = "flow_resources"
 
-  val STAR_UP = "startup"
+  val START_UP = "startup"
 
   val YARN_QUEUE = "wds.linkis.rm.yarnqueue"
 
+  val CONFIGURATION = "configuration"
+
 }
diff --git a/.../com/webank/wedatasphere/dss/flow/execution/entrance/execution/DefaultFlowExecution.scala b/.../com/webank/wedatasphere/dss/flow/execution/entrance/execution/DefaultFlowExecution.scala
@@ -74,8 +74,7 @@ class DefaultFlowExecution extends FlowExecution with Logging {
         info(s"${flowEntranceJob.getId} Submit nodes(${runningNodes.size}) to running")
         runningNodes.foreach { node =>
           node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.PROPS_MAP).asInstanceOf[java.util.Map[String, Any]].putAll(flowEntranceJob.getParams)
-//          val starUp = node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.STAR_UP).asInstanceOf[java.util.Map[String, Any]]
-//          starUp.put(FlowExecutionEntranceConfiguration.YARN_QUEUE, null)
+          node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.CONFIGURATION).asInstanceOf[java.util.Map[String, Any]].get(FlowExecutionEntranceConfiguration.START_UP).asInstanceOf[java.util.Map[String, Any]].put(FlowExecutionEntranceConfiguration.YARN_QUEUE, null)
           info(s"nodeParams:${node.getNode.getDSSNode.getParams} ")
           info(s"JobContent:${node.getNode.getDSSNode.getJobContent} ")
           node.run()