From 6f1e929053f03aa85ead848e4abcecb5135b93ab Mon Sep 17 00:00:00 2001
From: xlinliu <arionliu@webank.com>
Date: Sat, 21 Oct 2023 12:15:01 +0800
Subject: [PATCH] throw FlowExecutionErrorException cause

---
 .../execution/entrance/engine/FlowEntranceEngine.scala    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/engine/FlowEntranceEngine.scala b/dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/engine/FlowEntranceEngine.scala
index 06af622260..c47f6f269f 100644
--- a/dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/engine/FlowEntranceEngine.scala
+++ b/dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/src/main/scala/com/webank/wedatasphere/dss/flow/execution/entrance/engine/FlowEntranceEngine.scala
@@ -71,8 +71,12 @@ class FlowEntranceEngine extends Executor with ConcurrentTaskOperateSupport with
                   for (flowParser <- flowParsers) {
                     flowParser.parse(job)
                   }
-                }{ t =>
-                   throw new FlowExecutionErrorException(90101, s"Failed to parser flow of job(${job.getId})", t)
+                } { t =>
+                  if (t.isInstanceOf[FlowExecutionErrorException]) {
+                    throw t
+                  } else {
+                    throw new FlowExecutionErrorException(90101, s"Failed to parser flow of job(${job.getId})", t)
+                  }
                 }
               }
               this.SUBMIT_JOB_LOCK.synchronized {