diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/ExportJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/ExportJob.java index 98cfb443ec810b..554185a2ed677d 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/ExportJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/ExportJob.java @@ -703,6 +703,9 @@ private void cancelExportJobUnprotected(ExportFailMsg.CancelType type, String ms finishTimeMs = System.currentTimeMillis(); failMsg = new ExportFailMsg(type, msg); jobExecutorList.clear(); + selectStmtListPerParallel.clear(); + allOutfileInfo.clear(); + partitionToVersion.clear(); if (FeConstants.runningUnitTest) { return; } @@ -750,6 +753,9 @@ private void finishExportJobUnprotected() { outfileInfo = GsonUtils.GSON.toJson(allOutfileInfo); // Clear the jobExecutorList to release memory. jobExecutorList.clear(); + selectStmtListPerParallel.clear(); + allOutfileInfo.clear(); + partitionToVersion.clear(); Env.getCurrentEnv().getEditLog().logExportUpdateState(this, ExportJobState.FINISHED); LOG.info("finish export job {}", id); }