diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java index 2a0aeda..8379b62 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java @@ -144,6 +144,9 @@ public int execute(DriverContext driverContext) { rc = 1; } finally { startTime = perfLogger.getEndTime(PerfLogger.SPARK_SUBMIT_TO_RUNNING); + if (startTime < submitTime) { + startTime = submitTime; + } finishTime = perfLogger.getEndTime(PerfLogger.SPARK_RUN_JOB); Utilities.clearWork(conf); if (sparkSession != null && sparkSessionManager != null) {