From 2dc09c627fe1d32c63e9a7551390540581916d7d Mon Sep 17 00:00:00 2001 From: Manhua Date: Sun, 5 Dec 2021 14:03:29 +0800 Subject: [PATCH] [Fix-5551][common] Fix ExecutionStatus for hive-on-Tez application (#6289) * add ENDED state * Update HadoopUtils.java --- .../java/org/apache/dolphinscheduler/common/Constants.java | 4 ++++ .../org/apache/dolphinscheduler/common/utils/HadoopUtils.java | 1 + 2 files changed, 5 insertions(+) diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java index afa4ae9307..9efafc8f50 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java @@ -436,6 +436,10 @@ public final class Constants { * SUCCEEDED */ public static final String SUCCEEDED = "SUCCEEDED"; + /** + * ENDED + */ + public static final String ENDED = "ENDED"; /** * NEW */ diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/HadoopUtils.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/HadoopUtils.java index a7c880db1c..aab69e0929 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/HadoopUtils.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/HadoopUtils.java @@ -453,6 +453,7 @@ public class HadoopUtils implements Closeable { case Constants.ACCEPTED: return ExecutionStatus.SUBMITTED_SUCCESS; case Constants.SUCCEEDED: + case Constants.ENDED: return ExecutionStatus.SUCCESS; case Constants.NEW: case Constants.NEW_SAVING: