[kylin] branch main updated: KYLIN-5008: Status code is not handled correctly by the Kylin job.

[xxyu]

This is an automated email from the ASF dual-hosted git repository.

xxyu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/main by this push:
     new 2d1796ea4b KYLIN-5008: Status code is not handled correctly by the 
Kylin job.
2d1796ea4b is described below

commit 2d1796ea4b5f9b41db90bacf8b9fb5e51ee824cf
Author: Alexander Sidorchuk <alex.sidorchu...@gmail.com>
AuthorDate: Mon Sep 19 13:49:29 2022 +0300

    KYLIN-5008: Status code is not handled correctly by the Kylin job.
---
 .../src/main/scala/org/apache/spark/application/JobWorkSpace.scala   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobWorkSpace.scala
 
b/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobWorkSpace.scala
index a4ddf257f6..7d1a324647 100644
--- 
a/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobWorkSpace.scala
+++ 
b/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobWorkSpace.scala
@@ -36,7 +36,10 @@ object JobWorkSpace extends Logging {
       val monitor = new JobMonitor(eventLoop)
       val workspace = new JobWorkSpace(eventLoop, monitor, worker)
       if (System.getProperty("spark.master").equals("yarn") && 
System.getProperty("spark.submit.deployMode").equals("cluster")) {
-        workspace.run()
+        val res = workspace.run()
+        if (res != 0) {
+          System.exit(res)
+        }
       } else {
         System.exit(workspace.run())
       }