Skip to content

Commit ebb8a91

Browse files
EricGao888davidzollo
authored andcommitted
[Fix-17473] [Task Plugin] Fix Serverless Spark Task final state incorrect for failure (apache#17475)
1 parent 77b9e3c commit ebb8a91

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)