[enhancement](repeat) add filter in repeat node in BE (#21984)

2023-07-20 17:25:13 +08:00
parent be2754e1a2
commit 650d7cfc8c
1 changed files with 1 additions and 1 deletions
--- a/be/src/vec/exec/vrepeat_node.cpp
+++ b/be/src/vec/exec/vrepeat_node.cpp
@ -209,7 +209,7 @@ Status VRepeatNode::pull(doris::RuntimeState* state, vectorized::Block* output_b
            _repeat_id_idx = 0;
        }
    }
-
+    RETURN_IF_ERROR(VExprContext::filter_block(_conjuncts, output_block, output_block->columns()));
    *eos = _child_eos && _child_block.rows() == 0;
    reached_limit(output_block, eos);
    COUNTER_SET(_rows_returned_counter, _num_rows_returned);