From 650d7cfc8ce8c768319f4715a265f5f77898e04b Mon Sep 17 00:00:00 2001 From: zhangstar333 <87313068+zhangstar333@users.noreply.github.com> Date: Thu, 20 Jul 2023 17:25:13 +0800 Subject: [PATCH] [enhancement](repeat) add filter in repeat node in BE (#21984) [enhancement](repeat) add filter in repeat node in BE (#21984) --- be/src/vec/exec/vrepeat_node.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/vec/exec/vrepeat_node.cpp b/be/src/vec/exec/vrepeat_node.cpp index 7ac697338e..d7499de803 100644 --- 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);