File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
be/src/exec/pipeline/nljoin Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change 22
22
#include " runtime/current_thread.h"
23
23
#include " runtime/descriptors.h"
24
24
#include " simd/simd.h"
25
+ #include " storage/chunk_helper.h"
25
26
26
27
namespace starrocks ::pipeline {
27
28
@@ -662,8 +663,11 @@ Status NLJoinProbeOperator::_permute_right_join(size_t chunk_size) {
662
663
}
663
664
}
664
665
permute_rows += chunk->num_rows ();
665
-
666
- RETURN_IF_ERROR (eval_conjuncts (_conjunct_ctxs, chunk.get (), nullptr ));
666
+ {
667
+ CommonExprEvalScopeGuard guard (chunk, _common_expr_ctxs);
668
+ RETURN_IF_ERROR (guard.evaluate ());
669
+ RETURN_IF_ERROR (eval_conjuncts (_conjunct_ctxs, chunk.get (), nullptr ));
670
+ }
667
671
RETURN_IF_ERROR (_output_accumulator.push (std::move (chunk)));
668
672
match_flag_index += cur_chunk_size;
669
673
}
You can’t perform that action at this time.
0 commit comments