From e705f99e77bc624c94d7dfe30d0faf4a6a81bc92 Mon Sep 17 00:00:00 2001 From: BePPPower Date: Fri, 15 Nov 2024 14:58:42 +0800 Subject: [PATCH] fix 1 --- .../src/main/java/org/apache/doris/load/ExportJob.java | 6 ++++++ 1 file changed, 6 insertions(+) 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); }