(dolphinscheduler) branch dev updated: [Fix-17473] [Task Plugin] Fix Serverless Spark Task final state incorrect for failure (#17475)

[wenjun]

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

wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 590d16f22c [Fix-17473] [Task Plugin] Fix Serverless Spark Task final 
state incorrect for failure (#17475)
590d16f22c is described below

commit 590d16f22c0238142328f9ef3a2a90aa3cbac0a7
Author: Eric Gao <ericgao.apa...@gmail.com>
AuthorDate: Thu Sep 4 23:26:25 2025 +0800

    [Fix-17473] [Task Plugin] Fix Serverless Spark Task final state incorrect 
for failure (#17475)
---
 .../task/aliyunserverlessspark/AliyunServerlessSparkTask.java  |  2 +-
 .../aliyunserverlessspark/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 8824665180..c66cc23790 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 @@ public class AliyunServerlessSparkTask extends 
AbstractRemoteTask {
             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 6a29356fa7..74547497af 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 class AliyunServerlessSparkTaskTest {
         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));
+    }
 }