[Bug][Export] Fix bug of one more record showed in the “show export limit n" (#6012)
This commit is contained in:
@ -215,7 +215,7 @@ public class ExportMgr {
|
||||
|
||||
exportJobInfos.add(jobInfo);
|
||||
|
||||
if (counter++ >= resultNum) {
|
||||
if (++counter >= resultNum) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
@ -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);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user