Skip to content

Commit 5aa7bb4

Browse files
committed
test ci
1 parent 8c4d921 commit 5aa7bb4

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/AbstractTaskStateAction.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,11 @@ protected void releaseTaskInstanceResourcesIfNeeded(final ITaskExecutionRunnable
104104
public void onFatalEvent(final IWorkflowExecutionRunnable workflowExecutionRunnable,
105105
final ITaskExecutionRunnable taskExecutionRunnable,
106106
final TaskFatalLifecycleEvent taskFatalEvent) {
107+
throwExceptionIfStateIsNotMatch(taskExecutionRunnable);
108+
if (taskExecutionRunnable.getTaskInstance().getState().isFinished()) {
109+
logWarningIfCannotDoAction(taskExecutionRunnable, taskFatalEvent);
110+
return;
111+
}
107112
releaseTaskInstanceResourcesIfNeeded(taskExecutionRunnable);
108113
persistentTaskInstanceFatalEventToDB(taskExecutionRunnable, taskFatalEvent);
109114

dolphinscheduler-master/src/test/resources/logback.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@
6969
</appender>
7070

7171
<!-- We use OFF here to avoid too many exception log in CI -->
72-
<root level="OFF">
72+
<root level="INFO">
7373
<appender-ref ref="STDOUT"/>
7474
<appender-ref ref="TASKLOGFILE"/>
7575
<appender-ref ref="MASTERLOGFILE"/>

0 commit comments

Comments
 (0)