|
|
@@ -163,7 +163,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
|
|
|
if (Objects.isNull(jobId) || jobId.isEmpty()) {
|
|
|
SdExecutionTask update = new SdExecutionTask();
|
|
|
update.setId(sdExecutionTask.getId());
|
|
|
- update.setExternalJobId("任务提交失败:未获取到jobId");
|
|
|
+ update.setErrorMsg("任务提交失败:未获取到jobId");
|
|
|
update.setTaskStatus(ExecutionTaskStatusEnum.FAILED.getValue());
|
|
|
int rows = sdExecutionTaskMapper.updateById(update);
|
|
|
log.info("subTask submit failure, id:{} rows = {}", sdExecutionTask.getId(), rows);
|
|
|
@@ -183,7 +183,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
|
|
|
}
|
|
|
SdExecutionTask update = new SdExecutionTask();
|
|
|
update.setId(sdExecutionTask.getId());
|
|
|
- update.setExternalJobId("任务提交失败:" + e.getMessage());
|
|
|
+ update.setErrorMsg("任务提交失败:" + e.getMessage());
|
|
|
update.setTaskStatus(ExecutionTaskStatusEnum.FAILED.getValue());
|
|
|
int rows = sdExecutionTaskMapper.updateById(update);
|
|
|
log.info("subTask submit failure, id:{} rows = {}", sdExecutionTask.getId(), rows);
|