fix stream load fail (apache#34)

fe/fe-core/src/main/java/org/apache/doris/common/util/VectorizedUtil.java

@@ -0,0 +1,30 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package org.apache.doris.common.util;
+
+import org.apache.doris.qe.ConnectContext;
+
+public class VectorizedUtil {
+    public static boolean isVectorized() {
+        if (ConnectContext.get() == null) {
+            return false;
+        }
+        return ConnectContext.get().getSessionVariable().enableVectorizedEngine();
+    }
+}
+

fe/fe-core/src/main/java/org/apache/doris/planner/PlanNode.java

@@ -31,7 +31,7 @@
 import org.apache.doris.common.AnalysisException;
 import org.apache.doris.common.TreeNode;
 import org.apache.doris.common.UserException;
-import org.apache.doris.qe.ConnectContext;
+import org.apache.doris.common.util.VectorizedUtil;
 import org.apache.doris.thrift.TExplainLevel;
 import org.apache.doris.thrift.TFunctionBinaryType;
 import org.apache.doris.thrift.TPlan;
@@ -136,7 +136,7 @@ protected PlanNode(PlanNodeId id, ArrayList<TupleId> tupleIds, String planNodeNa
         this.tupleIds = Lists.newArrayList(tupleIds);
         this.tblRefIds = Lists.newArrayList(tupleIds);
         this.cardinality = -1;
-        this.planNodeName = ConnectContext.get().getSessionVariable().enableVectorizedEngine() ?
+        this.planNodeName = VectorizedUtil.isVectorized() ?
                 "V" + planNodeName : planNodeName;
         this.numInstances = 1;
     }
@@ -147,7 +147,7 @@ protected PlanNode(PlanNodeId id, String planNodeName) {
         this.tupleIds = Lists.newArrayList();
         this.tblRefIds = Lists.newArrayList();
         this.cardinality = -1;
-        this.planNodeName = ConnectContext.get().getSessionVariable().enableVectorizedEngine() ?
+        this.planNodeName = VectorizedUtil.isVectorized() ?
                 "V" + planNodeName : planNodeName;
         this.numInstances = 1;
     }
@@ -164,7 +164,7 @@ protected PlanNode(PlanNodeId id, PlanNode node, String planNodeName) {
         this.conjuncts = Expr.cloneList(node.conjuncts, null);
         this.cardinality = -1;
         this.compactData = node.compactData;
-        this.planNodeName = ConnectContext.get().getSessionVariable().enableVectorizedEngine() ?
+        this.planNodeName = VectorizedUtil.isVectorized() ?
                 "V" + planNodeName : planNodeName;
         this.numInstances = 1;
     }