[kylin] branch main updated: KYLIN-5090 The error message was not printed in class JobWoker

[xx...@apache.org]

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 c99b982  KYLIN-5090 The error message was not printed in class JobWoker
c99b982 is described below

commit c99b98270bb9cab357fd7cc45df83b3678dca870
Author: yaqian.zhang <59...@qq.com>
AuthorDate: Tue Nov 9 17:38:21 2021 +0800

    KYLIN-5090 The error message was not printed in class JobWoker
---
 .../src/main/scala/org/apache/spark/application/JobMonitor.scala        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobMonitor.scala b/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobMonitor.scala
index d02e129..f5d1d8f 100644
--- a/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobMonitor.scala
+++ b/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/spark/application/JobMonitor.scala
@@ -43,12 +43,12 @@ class JobMonitor(eventLoop: KylinJobEventLoop) extends Logging {
 
   def handleResourceLack(rl: ResourceLack): Unit = {
     try {
+      logError(s"Job failed the $retryTimes times.", rl.throwable)
       val buildEnv = KylinBuildEnv.get()
       retryTimes += 1
       KylinBuildEnv.get().buildJobInfos.recordRetryTimes(retryTimes)
       val maxRetry = buildEnv.kylinConfig.getSparkEngineMaxRetryTime
       if (retryTimes <= maxRetry) {
-        logError(s"Job failed the $retryTimes times.", rl.throwable)
         System.setProperty("kylin.spark-conf.auto.prior", "false")
         ExceptionTerminator.resolveException(rl, eventLoop)
       } else {