This is an automated email from the ASF dual-hosted git repository.
wuweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git
The following commit(s) were added to refs/heads/master by this push:
new 36c2e38 Fix itemErrorMessages not cleared where job finished, (#2021)
36c2e38 is described below
commit 36c2e38715ddb6ce17ac7de9ccb1adbec3d3cf04
Author: smartBun <[email protected]>
AuthorDate: Sun Dec 26 18:45:47 2021 +0800
Fix itemErrorMessages not cleared where job finished, (#2021)
caused error message show again in next loop status trace event
Co-authored-by: liyang <[email protected]>
---
.../apache/shardingsphere/elasticjob/executor/ElasticJobExecutor.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/elasticjob-ecosystem/elasticjob-executor/elasticjob-executor-kernel/src/main/java/org/apache/shardingsphere/elasticjob/executor/ElasticJobExecutor.java
b/elasticjob-ecosystem/elasticjob-executor/elasticjob-executor-kernel/src/main/java/org/apache/shardingsphere/elasticjob/executor/ElasticJobExecutor.java
index 1b54eae..6a879be 100644
---
a/elasticjob-ecosystem/elasticjob-executor/elasticjob-executor-kernel/src/main/java/org/apache/shardingsphere/elasticjob/executor/ElasticJobExecutor.java
+++
b/elasticjob-ecosystem/elasticjob-executor/elasticjob-executor-kernel/src/main/java/org/apache/shardingsphere/elasticjob/executor/ElasticJobExecutor.java
@@ -129,6 +129,7 @@ public final class ElasticJobExecutor {
jobFacade.postJobStatusTraceEvent(taskId, State.TASK_FINISHED,
"");
} else {
jobFacade.postJobStatusTraceEvent(taskId, State.TASK_ERROR,
itemErrorMessages.toString());
+ itemErrorMessages.clear();
}
}
}