database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](Job)Job Task does not display error message (#24897)

Browse Source
This commit is contained in:
Calvin Kirs
2023-09-28 14:47:12 +08:00
committed by GitHub
parent b6babf3af4
commit 377554ee1c
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/TaskHandler.java
View File

@ -125,7 +125,7 @@ public class TaskHandler implements WorkHandler<TaskEvent> {
jobTask.setIsSuccessful(result.isSuccess());
if (!result.isSuccess()) {
log.warn("Job execute failed, jobId: {}, msg : {}", jobId, result.getExecutorSql());
jobTask.setErrorMsg(result.getExecutorSql());
jobTask.setErrorMsg(result.getErrorMsg());
timerJobManager.pauseJob(jobId);
}
jobTask.setExecuteSql(result.getExecutorSql());

3
fe/fe-core/src/main/java/org/apache/doris/scheduler/executor/SqlJobExecutor.java
View File

@ -36,7 +36,6 @@ import java.util.UUID;
/**
* we use this executor to execute sql job
*
*/
@Slf4j
public class SqlJobExecutor implements JobExecutor {
@ -71,7 +70,7 @@ public class SqlJobExecutor implements JobExecutor {
return new ExecutorResult<>(result, true, null, sql);
} catch (Exception e) {
log.warn("execute sql job failed, sql: {}, error: {}", sql, e.getMessage());
log.warn("execute sql job failed, job id :{}, sql: {}, error: {}", job.getJobId(), sql, e);
return new ExecutorResult<>(null, false, e.getMessage(), sql);
}