From 4bc758384986be1818aeb89e837d06fc122e3de2 Mon Sep 17 00:00:00 2001 From: morningman Date: Wed, 20 Dec 2023 21:31:44 +0800 Subject: [PATCH] 1 --- .../main/java/org/apache/doris/analysis/ExportStmt.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java index 686dfcc6fcf133..1b33630e802aac 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java @@ -124,9 +124,12 @@ public ExportStmt(TableRef tableRef, Expr whereExpr, String path, this.lineDelimiter = DEFAULT_LINE_DELIMITER; this.timeout = DEFAULT_TIMEOUT; - Optional optionalSessionVariable = Optional.ofNullable( - ConnectContext.get().getSessionVariable()); - this.sessionVariables = optionalSessionVariable.orElse(VariableMgr.getDefaultSessionVariable()); + // ConnectionContext may not exist when in replay thread + if (ConnectContext.get() != null) { + this.sessionVariables = VariableMgr.cloneSessionVariable(ConnectContext.get().getSessionVariable()); + } else { + this.sessionVariables = VariableMgr.cloneSessionVariable(VariableMgr.getDefaultSessionVariable()); + } } @Override