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 577aeae564..51019ca17b 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 class ExportMgr { 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 744a4806e1..9b72d5dda6 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 @@ -246,6 +246,8 @@ public class ExportExportingTask extends MasterTask { 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); }