database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Chore](runtime-filter) add check is broadcast on nlj (#33088)

Browse Source 
add check is broadcast on nlj
This commit is contained in:
Pxl
2024-04-01 15:46:54 +08:00
committed by yiguolei
parent 797b8fa456
commit 113bada7ed
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
be/src/pipeline/exec/nested_loop_join_build_operator.cpp
View File

@ -44,6 +44,11 @@ Status NestedLoopJoinBuildSinkLocalState::init(RuntimeState* state, LocalSinkSta
for (size_t i = 0; i < p._runtime_filter_descs.size(); i++) {
RETURN_IF_ERROR(state->register_producer_runtime_filter(
p._runtime_filter_descs[i], p._need_local_merge, &_runtime_filters[i], false));
if (!_runtime_filters[i]->is_broadcast_join()) {
return Status::InternalError(
"runtime filter({}) on NestedLoopJoin should be set to is_broadcast_join,",
_runtime_filters[i]->get_name());
}
}
return Status::OK();
}

2
fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilter.java
View File

@ -685,7 +685,7 @@ public final class RuntimeFilter {
if (node instanceof HashJoinNode) {
setIsBroadcast(((HashJoinNode) node).getDistributionMode() == HashJoinNode.DistributionMode.BROADCAST);
} else {
setIsBroadcast(false);
setIsBroadcast(true);
}
if (LOG.isTraceEnabled()) {
LOG.trace("Runtime filter: " + debugString());