diff --git a/be/src/vec/exprs/vexpr_context.cpp b/be/src/vec/exprs/vexpr_context.cpp index 199c8076d8ea1c..019a7d802cab74 100644 --- a/be/src/vec/exprs/vexpr_context.cpp +++ b/be/src/vec/exprs/vexpr_context.cpp @@ -118,7 +118,7 @@ Status VExprContext::filter_block(VExprContext* vexpr_ctx, Block* block, int col return Status::OK(); } int result_column_id = -1; - vexpr_ctx->execute(block, &result_column_id); + RETURN_IF_ERROR(vexpr_ctx->execute(block, &result_column_id)); return Block::filter_block(block, result_column_id, column_to_keep); }