This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 4ddef31c208 (fix)[meta][export] fix replay export NPE issue (#28752)
4ddef31c208 is described below
commit 4ddef31c208c54f711e1ea3517d6951a35fb12c1
Author: Mingyu Chen <morning...@163.com>
AuthorDate: Thu Dec 21 14:39:00 2023 +0800
(fix)[meta][export] fix replay export NPE issue (#28752)
The ConnectionContext does not exist in replay thread
---
.../src/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 686dfcc6fcf..1b33630e802 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 class ExportStmt extends StatementBase {
this.lineDelimiter = DEFAULT_LINE_DELIMITER;
this.timeout = DEFAULT_TIMEOUT;
- Optional<SessionVariable> 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
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
