Skip to content

Commit 590d16f

Browse files
authored
[Fix-17473] [Task Plugin] Fix Serverless Spark Task final state incorrect for failure (#17475)
1 parent dbb7c4c commit 590d16f

2 files changed

Lines changed: 11 additions & 1 deletion

File tree

dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -197,7 +197,7 @@ protected int mapFinalStateToExitCode(RunState state) {
197197
case Success:
198198
return TaskConstants.EXIT_CODE_SUCCESS;
199199
case Failed:
200-
return TaskConstants.EXIT_CODE_KILL;
200+
return TaskConstants.EXIT_CODE_FAILURE;
201201
default:
202202
return TaskConstants.EXIT_CODE_FAILURE;
203203
}

dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/test/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTaskTest.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -222,4 +222,14 @@ public void testBuildStartJobRunRequest() {
222222
verify(mockAliyunServerlessSparkParameters).getEngineReleaseVersion();
223223
verify(mockAliyunServerlessSparkParameters).isProduction();
224224
}
225+
226+
@Test
227+
public void testMapFinalStateToExitCode() {
228+
Assertions.assertEquals(TaskConstants.EXIT_CODE_SUCCESS,
229+
aliyunServerlessSparkTask.mapFinalStateToExitCode(RunState.Success));
230+
Assertions.assertEquals(TaskConstants.EXIT_CODE_FAILURE,
231+
aliyunServerlessSparkTask.mapFinalStateToExitCode(RunState.Failed));
232+
Assertions.assertEquals(TaskConstants.EXIT_CODE_FAILURE,
233+
aliyunServerlessSparkTask.mapFinalStateToExitCode(RunState.Cancelled));
234+
}
225235
}

0 commit comments

Comments
 (0)