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 9e50d9318558a0..852c3ff94feb8f 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 @@ -705,6 +705,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; } @@ -752,6 +755,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); }