From 47a1315ceec7eff695e8301dcc2c2127987dd4e8 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Tue, 25 Feb 2025 09:27:05 +0800
Subject: [PATCH] branch-2.1: [fix](Export) Clone `SessionVariable` for each
 ExportTaskExecutor #48239 (#48255)

Cherry-picked from #48239

Co-authored-by: Tiewei Fang <fangtiewei@selectdb.com>
---
 .../main/java/org/apache/doris/load/ExportTaskExecutor.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/ExportTaskExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/load/ExportTaskExecutor.java
index 731a26ab12..a1fffffeef 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/ExportTaskExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/ExportTaskExecutor.java
@@ -34,6 +34,7 @@ import org.apache.doris.qe.AutoCloseConnectContext;
 import org.apache.doris.qe.ConnectContext;
 import org.apache.doris.qe.QueryState.MysqlStateType;
 import org.apache.doris.qe.StmtExecutor;
+import org.apache.doris.qe.VariableMgr;
 import org.apache.doris.scheduler.exception.JobException;
 import org.apache.doris.scheduler.executor.TransientTaskExecutor;
 import org.apache.doris.thrift.TUniqueId;
@@ -169,7 +170,7 @@ public class ExportTaskExecutor implements TransientTaskExecutor {
     private AutoCloseConnectContext buildConnectContext() {
         ConnectContext connectContext = new ConnectContext();
         exportJob.getSessionVariables().setQueryTimeoutS(exportJob.getTimeoutSecond());
-        connectContext.setSessionVariable(exportJob.getSessionVariables());
+        connectContext.setSessionVariable(VariableMgr.cloneSessionVariable(exportJob.getSessionVariables()));
         // The rollback to the old optimizer is prohibited
         // Since originStmt is empty, reverting to the old optimizer when the new optimizer is enabled is meaningless.
         connectContext.getSessionVariable().enableFallbackToOriginalPlanner = false;