Revert "[fix](executor) only mysql connect to set GlobalPipelineTask (a…

…pache#22205)" This reverts commit 25f2619.
HappenLee · Aug 4, 2023 · bae363d · bae363d
1 parent 672acb8
commit bae363d
Showing 1 changed file with 1 addition and 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
@@ -263,7 +263,7 @@ public ConnectContext(StreamConnection connection) {
             mysqlChannel = new DummyMysqlChannel();
         }
         sessionVariable = VariableMgr.newSessionVariable();
-        if (connection != null && isMajorVersionUpgrade) {
+        if (isMajorVersionUpgrade) {
             VariableMgr.setGlobalPipelineTask(sessionVariable.parallelExecInstanceNum);
             sessionVariable = VariableMgr.newSessionVariable();
         }