From 22b3f0cbfe3189fc04ba17f3b135941cf6be3549 Mon Sep 17 00:00:00 2001 From: EricGao888 Date: Thu, 4 Sep 2025 15:16:30 +0800 Subject: [PATCH] [BUG-17473] fix aliyun ss task final state --- .../AliyunServerlessSparkTask.java | 2 +- .../AliyunServerlessSparkTaskTest.java | 10 ++++++++++ 2 files changed, 11 insertions(+), 1 deletion(-) diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java index 882466518089..c66cc23790d4 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java @@ -197,7 +197,7 @@ protected int mapFinalStateToExitCode(RunState state) { case Success: return TaskConstants.EXIT_CODE_SUCCESS; case Failed: - return TaskConstants.EXIT_CODE_KILL; + return TaskConstants.EXIT_CODE_FAILURE; default: return TaskConstants.EXIT_CODE_FAILURE; } diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/test/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTaskTest.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/test/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTaskTest.java index 6a29356fa779..74547497afd3 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/test/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTaskTest.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/test/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTaskTest.java @@ -222,4 +222,14 @@ public void testBuildStartJobRunRequest() { verify(mockAliyunServerlessSparkParameters).getEngineReleaseVersion(); verify(mockAliyunServerlessSparkParameters).isProduction(); } + + @Test + public void testMapFinalStateToExitCode() { + Assertions.assertEquals(TaskConstants.EXIT_CODE_SUCCESS, + aliyunServerlessSparkTask.mapFinalStateToExitCode(RunState.Success)); + Assertions.assertEquals(TaskConstants.EXIT_CODE_FAILURE, + aliyunServerlessSparkTask.mapFinalStateToExitCode(RunState.Failed)); + Assertions.assertEquals(TaskConstants.EXIT_CODE_FAILURE, + aliyunServerlessSparkTask.mapFinalStateToExitCode(RunState.Cancelled)); + } }