From 80918480f2fd67e68b695bc7b9225f23d2b1b84e Mon Sep 17 00:00:00 2001 From: WindyGao <1254097913@qq.com> Date: Thu, 20 May 2021 02:39:36 -0400 Subject: [PATCH 1/2] ExportJob ErrorMsg is "type:UNKNOWN; msg: "when job cancelled cause by time out,fix it --- .../main/java/org/apache/doris/task/ExportExportingTask.java | 2 ++ 1 file changed, 2 insertions(+) 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); } From 7c031f043c1465381a8985cb3f1222fea2796d73 Mon Sep 17 00:00:00 2001 From: WindyGao <1254097913@qq.com> Date: Sat, 22 May 2021 22:56:15 -0400 Subject: [PATCH 2/2] fix show export limit --- fe/fe-core/src/main/java/org/apache/doris/load/ExportMgr.java | 2 +- 1 file changed, 1 insertion(+), 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 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; } }