[fix](hashjoin) return error if in progress of upgrade (#13753)

This commit is contained in:
TengJianPing
2022-10-31 09:41:20 +08:00
committed by GitHub
parent f5761c658f
commit 2b9e1878a2

View File

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