This is an automated email from the ASF dual-hosted git repository.
lihaopeng 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 25f26198f4 [fix](executor) only mysql connect to set
GlobalPipelineTask (#22205)
25f26198f4 is described below
commit 25f26198f4a9e5ebd3ba58a770b185f0818d7b18
Author: Mryange <59914473+mrya...@users.noreply.github.com>
AuthorDate: Fri Jul 28 16:19:34 2023 +0800
[fix](executor) only mysql connect to set GlobalPipelineTask (#22205)
---
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
index bc7b5273c3..1a1f5cda1f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
@@ -263,7 +263,7 @@ public class ConnectContext {
mysqlChannel = new DummyMysqlChannel();
}
sessionVariable = VariableMgr.newSessionVariable();
- if (isMajorVersionUpgrade) {
+ if (connection != null && isMajorVersionUpgrade) {
VariableMgr.setGlobalPipelineTask(sessionVariable.parallelExecInstanceNum);
sessionVariable = VariableMgr.newSessionVariable();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
