[Exec] Add conjection for union_node. (#16777)

2023-02-20 10:48:58 +08:00
parent 97230a54fb
commit e958b13747
1 changed files with 1 additions and 0 deletions
--- a/be/src/vec/exec/vunion_node.cpp
+++ b/be/src/vec/exec/vunion_node.cpp
@ -283,6 +283,7 @@ Status VUnionNode::get_next(RuntimeState* state, Block* block, bool* eos) {
    } else if (has_more_const(state)) {
        RETURN_IF_ERROR(get_next_const(state, block));
    }
+    RETURN_IF_ERROR(VExprContext::filter_block(_vconjunct_ctx_ptr, block, block->columns()));

    *eos = (!has_more_passthrough() && !has_more_materialized() && !has_more_const(state));
    reached_limit(block, eos);