From 9bc2df43a764bc6f67e8d146d52e20e014bf46e4 Mon Sep 17 00:00:00 2001 From: GeoffreyStark <36130371+WindyGao@users.noreply.github.com> Date: Sun, 20 Jun 2021 16:10:21 +0800 Subject: [PATCH] =?UTF-8?q?[Bug][Export]=20Fix=20bug=20of=20one=20more=20r?= =?UTF-8?q?ecord=20showed=20in=20the=20=E2=80=9Cshow=20export=20limit=20n"?= =?UTF-8?q?=20(#6012)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- fe/fe-core/src/main/java/org/apache/doris/load/ExportMgr.java | 2 +- .../main/java/org/apache/doris/task/ExportExportingTask.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) 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); }