This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 632fa510b9e6848e6110117a34875173b0960dee
Author: zhangstar333 <[email protected]>
AuthorDate: Thu Jul 20 17:25:13 2023 +0800

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


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to