This is an automated email from the ASF dual-hosted git repository.
englefly pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 827d2c46de1 [fix](nereids) planner should always gennerate bitmap
runtime filter #32960
827d2c46de1 is described below
commit 827d2c46de10350f72a065029ccb4914f975a71d
Author: minghong <[email protected]>
AuthorDate: Thu Mar 28 15:36:49 2024 +0800
[fix](nereids) planner should always gennerate bitmap runtime filter #32960
---
.../doris/nereids/glue/translator/RuntimeFilterTranslator.java | 8 +-------
.../doris/nereids/processor/post/RuntimeFilterGenerator.java | 3 +--
2 files changed, 2 insertions(+), 9 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/RuntimeFilterTranslator.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/RuntimeFilterTranslator.java
index e5d695bea83..6c25337ac98 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/RuntimeFilterTranslator.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/RuntimeFilterTranslator.java
@@ -147,13 +147,7 @@ public class RuntimeFilterTranslator {
origFilter.setIsBroadcast(((HashJoinNode)
node).getDistributionMode() == DistributionMode.BROADCAST);
} else {
// nest loop join
- if (filter.getType() == TRuntimeFilterType.BITMAP) {
- //bitmap rf requires isBroadCast=false, it always requires
merge filter
- origFilter.setIsBroadcast(false);
- } else {
- // min-max rf
- origFilter.setIsBroadcast(true);
- }
+ origFilter.setIsBroadcast(true);
}
boolean isLocalTarget = scanNodeList.stream().allMatch(e ->
!(e instanceof CTEScanNode) &&
e.getFragmentId().equals(node.getFragmentId()));
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
index 8bdb6c59573..55d990365a2 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
@@ -447,8 +447,7 @@ public class RuntimeFilterGenerator extends
PlanPostProcessor {
}
RuntimeFilterContext ctx = context.getRuntimeFilterContext();
- if ((ctx.getSessionVariable().getRuntimeFilterType() &
TRuntimeFilterType.BITMAP.getValue()) != 0
- &&
!ctx.getSessionVariable().isIgnoreStorageDataDistribution()) {
+ if ((ctx.getSessionVariable().getRuntimeFilterType() &
TRuntimeFilterType.BITMAP.getValue()) != 0) {
generateBitMapRuntimeFilterForNLJ(join, ctx);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
