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));