diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/ExportMgr.java b/fe/fe-core/src/main/java/org/apache/doris/load/ExportMgr.java index 577aeae5646090..51019ca17b0b86 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/ExportMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/ExportMgr.java @@ -215,7 +215,7 @@ public List> getExportJobInfosByIdOrState( exportJobInfos.add(jobInfo); - if (counter++ >= resultNum) { + if (++counter >= resultNum) { break; } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java b/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java index e8c9991fabadc7..e8dc32c2fb3432 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java @@ -243,6 +243,8 @@ public synchronized void onTimeout() { isCancelled = true; this.failStatus = new Status(TStatusCode.TIMEOUT, "timeout"); cancelType = ExportFailMsg.CancelType.TIMEOUT; + String failMsg = "export exporting job timeout."; + job.setFailMsg(new ExportFailMsg(cancelType, failMsg)); LOG.warn("export exporting job timeout. job: {}", job); }