From bae363d9b4ec75ef6df794613ea7246520f1d6de Mon Sep 17 00:00:00 2001
From: HappenLee <happenlee@hotmail.com>
Date: Fri, 4 Aug 2023 17:28:58 +0800
Subject: [PATCH] Revert "[fix](executor) only mysql connect to set
 GlobalPipelineTask (#22205)"

This reverts commit 25f26198f4a9e5ebd3ba58a770b185f0818d7b18.
---
 .../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 1a1f5cda1fbfc4..bc7b5273c310f3 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 ConnectContext(StreamConnection connection) {
             mysqlChannel = new DummyMysqlChannel();
         }
         sessionVariable = VariableMgr.newSessionVariable();
-        if (connection != null && isMajorVersionUpgrade) {
+        if (isMajorVersionUpgrade) {
             VariableMgr.setGlobalPipelineTask(sessionVariable.parallelExecInstanceNum);
             sessionVariable = VariableMgr.newSessionVariable();
         }