dss-server:fix code

WeDataSphere · Oct 18, 2024 · 9936147 · 9936147
1 parent b02ba33
commit 9936147
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../com/webank/wedatasphere/dss/flow/execution/entrance/execution/DefaultFlowExecution.scala b/.../com/webank/wedatasphere/dss/flow/execution/entrance/execution/DefaultFlowExecution.scala
@@ -77,8 +77,8 @@ class DefaultFlowExecution extends FlowExecution with Logging {
           if (node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.CONFIGURATION) != null && node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.CONFIGURATION).asInstanceOf[java.util.Map[String, Any]].get(FlowExecutionEntranceConfiguration.START_UP) != 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)
           }
-          if (node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.PROPS_MAP) != null && node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.PROPS_MAP).asInstanceOf[java.util.Map[String, Any]].get(FlowExecutionEntranceConfiguration.COMMAND) != null) {
-            node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.PROPS_MAP).asInstanceOf[java.util.Map[String, Any]].get(FlowExecutionEntranceConfiguration.COMMAND).asInstanceOf[java.util.Map[String, Any]].put(FlowExecutionEntranceConfiguration.USER_TO_PROXY, null)
+          if (node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.PROPS_MAP) != null ) {
+            node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.PROPS_MAP).asInstanceOf[java.util.Map[String, Any]].put(FlowExecutionEntranceConfiguration.USER_TO_PROXY, null)
           }
           if (node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.FLOW_VAR_MAP) != null) {
             node.getNode.getDSSNode.getParams.get(FlowExecutionEntranceConfiguration.FLOW_VAR_MAP).asInstanceOf[java.util.Map[String, Any]].put(FlowExecutionEntranceConfiguration.USER_TO_PROXY, null)