fix: 去除冗余代码#AI Commit#

Author: zqburde

dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/node/BranchNodeRunner.scala

@@ -101,17 +101,18 @@ class BranchNodeRunner(flow: Workflow) extends NodeRunner with Logging {
       val parsedRules = BranchExpressionUtils.parseBranchRules(branchRuleText)
       logInfo(s"Branch node ${node.getName} parsed rules: ${parsedRules.map(rule => s"${rule.condition}=>success=${rule.targetName.getOrElse("")},failure=${rule.onFailureTarget.getOrElse("")}").mkString(", ")}")
       val selectedEdge = selectEdgeByRules(outgoingEdges, parsedRules, context)
+      val selectedTarget = selectedEdge.map(_.getTarget).orNull
       if (selectedEdge.isEmpty) {
-        throw new IllegalStateException(s"No branch rule matched for node ${node.getName}.")
+        logInfo(s"Branch node ${node.getName} selected no downstream target.")
+      } else {
+        logInfo(s"Branch node ${node.getName} selected target id: ${Option(selectedTarget).getOrElse("")}")
       }
-      val selectedTarget = selectedEdge.map(_.getTarget).orNull
-      logInfo(s"Branch node ${node.getName} selected target id: ${Option(selectedTarget).getOrElse("")}")
       getNodeRunnerListener match {
         case flowEntranceJob: FlowEntranceJob =>
           flowEntranceJob.recordBranchSelection(currentNodeId, selectedTarget)
         case _ =>
       }
-      this.executedInfo = Option(selectedTarget).getOrElse("default")
+      this.executedInfo = Option(selectedTarget).getOrElse("")
       this.transitionState(NodeExecutionState.Succeed)
     } catch {
       case t: Throwable =>

plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/conf/LinkisJobTypeConf.java

@@ -44,12 +44,6 @@ public class LinkisJobTypeConf {
     public static final String LINKIS_TYPE_KEY = "linkistype";
     public static final String FLOW_VARIABLE_PREFIX = "flow.variable.";
 
-    public static final String BRANCH_ROUTE_LINKIS_TYPE = "linkis.appconn.branch.route";
-    public static final String BRANCH_ROUTE_NODE_ID = "wds.branch.route.node.id";
-    public static final String BRANCH_ROUTE_NODE_NAME = "wds.branch.route.node.name";
-    public static final String BRANCH_ROUTE_RULE_TEXT = "wds.branch.route.rule.text";
-    public static final String BRANCH_ROUTE_TARGETS = "wds.branch.route.targets";
-    public static final String BRANCH_GUARD_RULES = "wds.branch.guard.rules";
     public static final String BRANCH_OUTPUT_MAPPING = "node.conf.special.branch.output.mapping";
     public static final String BRANCH_OUTPUT_MAPPING_ALIAS = "node.conf.special.branchOutputMapping";