This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 47a1315ceec branch-2.1: [fix](Export) Clone `SessionVariable` for each
ExportTaskExecutor #48239 (#48255)
47a1315ceec is described below
commit 47a1315ceec7eff695e8301dcc2c2127987dd4e8
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Feb 25 09:27:05 2025 +0800
branch-2.1: [fix](Export) Clone `SessionVariable` for each
ExportTaskExecutor #48239 (#48255)
Cherry-picked from #48239
Co-authored-by: Tiewei Fang <[email protected]>
---
fe/fe-core/src/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 731a26ab121..a1fffffeef2 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;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
