From 2b9e1878a2db685ea2896899414634ec0012d0da Mon Sep 17 00:00:00 2001
From: TengJianPing <18241664+jacktengg@users.noreply.github.com>
Date: Mon, 31 Oct 2022 09:41:20 +0800
Subject: [PATCH] [fix](hashjoin) return error if in progress of upgrade
 (#13753)

---
 be/src/exec/exec_node.cpp | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/be/src/exec/exec_node.cpp b/be/src/exec/exec_node.cpp
index f04f832328..be94dcbb28 100644
--- a/be/src/exec/exec_node.cpp
+++ b/be/src/exec/exec_node.cpp
@@ -517,6 +517,13 @@ Status ExecNode::create_node(RuntimeState* state, ObjectPool* pool, const TPlanN
 
     case TPlanNodeType::HASH_JOIN_NODE:
         if (state->enable_vectorized_exec()) {
+            if (!tnode.hash_join_node.__isset.vintermediate_tuple_id_list) {
+                // in progress of upgrading from 1.1-lts to 1.2-lts
+                error_msg << "In progress of upgrading from 1.1-lts to 1.2-lts, vectorized hash "
+                             "join cannot be executed, you can switch to non-vectorized engine by "
+                             "'set global enable_vectorized_engine = false'";
+                return Status::InternalError(error_msg.str());
+            }
             *node = pool->add(new vectorized::HashJoinNode(pool, tnode, descs));
         } else {
             *node = pool->add(new HashJoinNode(pool, tnode, descs));