throw FlowExecutionErrorException cause

WeDataSphere · Oct 21, 2023 · 6f1e929 · 6f1e929
1 parent a583160
commit 6f1e929
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...scala/com/webank/wedatasphere/dss/flow/execution/entrance/engine/FlowEntranceEngine.scala b/...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 {