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 6138596620..d70a882c5c 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 @@ -127,14 +127,6 @@ public class RuntimeFilterTranslator { targetExpr = new CastExpr(src.getType(), targetExpr); } FilterSizeLimits filterSizeLimits = context.getLimits(); - if (node instanceof HashJoinNode - && !(((HashJoinNode) node).getDistributionMode() == DistributionMode.BROADCAST) - && ConnectContext.get() != null - && ConnectContext.get().getSessionVariable().enablePipelineEngine() - && ConnectContext.get().getSessionVariable().getParallelExecInstanceNum() > 0) { - filterSizeLimits = filterSizeLimits.adjustForParallel( - ConnectContext.get().getSessionVariable().getParallelExecInstanceNum()); - } org.apache.doris.planner.RuntimeFilter origFilter = org.apache.doris.planner.RuntimeFilter.fromNereidsRuntimeFilter( filter.getId(), node, src, filter.getExprOrder(), targetExpr, diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilterGenerator.java b/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilterGenerator.java index 2d4e57702c..a88f5d73bf 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilterGenerator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilterGenerator.java @@ -117,17 +117,6 @@ public final class RuntimeFilterGenerator { defaultValue = Math.max(defaultValue, minVal); defaultVal = BitUtil.roundUpToPowerOf2(Math.min(defaultValue, maxVal)); } - - private FilterSizeLimits(long maxVal, long minVal, long defaultVal) { - this.maxVal = BitUtil.roundUpToPowerOf2(maxVal); - this.minVal = BitUtil.roundUpToPowerOf2(minVal); - defaultVal = Math.max(defaultVal, this.minVal); - this.defaultVal = BitUtil.roundUpToPowerOf2(Math.min(defaultVal, this.maxVal)); - } - - public FilterSizeLimits adjustForParallel(int parallel) { - return new FilterSizeLimits(maxVal / parallel, minVal / parallel, defaultVal / parallel); - } } // Contains size limits for bloom filters.