This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push: new fccb7b8055 [fix](planner) Fix the bug of can't query the data of new added partition when set partition_prune_algorithm_version = 2 (#9844) fccb7b8055 is described below commit fccb7b805533f04557e9c0833e3ce00a402c39a0 Author: Kikyou1997 <33112463+kikyou1...@users.noreply.github.com> AuthorDate: Wed Jun 1 23:44:14 2022 +0800 [fix](planner) Fix the bug of can't query the data of new added partition when set partition_prune_algorithm_version = 2 (#9844) --- .../src/main/java/org/apache/doris/analysis/LiteralExpr.java | 1 + .../main/java/org/apache/doris/planner/ListPartitionPrunerV2.java | 7 ++++++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LiteralExpr.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LiteralExpr.java index 375fe8d27c..6d40c80acb 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/LiteralExpr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/LiteralExpr.java @@ -76,6 +76,7 @@ public abstract class LiteralExpr extends Expr implements Comparable<LiteralExpr case HLL: case STRING: literalExpr = new StringLiteral(value); + literalExpr.setType(type); break; case DATE: case DATETIME: diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/ListPartitionPrunerV2.java b/fe/fe-core/src/main/java/org/apache/doris/planner/ListPartitionPrunerV2.java index eefe8ba114..6d45efc8dd 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/ListPartitionPrunerV2.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/ListPartitionPrunerV2.java @@ -38,6 +38,11 @@ import java.util.Optional; import java.util.function.Function; import java.util.stream.Collectors; +/** + * ListPartitionPrunerV2 + * @since 1.0 + */ +@SuppressWarnings("UnstableApiUsage") public class ListPartitionPrunerV2 extends PartitionPrunerV2Base { private final Map<UniqueId, Range<PartitionKey>> uidToPartitionRange; @@ -131,7 +136,7 @@ public class ListPartitionPrunerV2 extends PartitionPrunerV2Base { // Convert the grouped map to a RangeMap. TreeRangeMap<ColumnBound, List<UniqueId>> candidateRangeMap = TreeRangeMap.create(); - grouped.forEach((k, v) -> candidateRangeMap.put(k, v)); + grouped.forEach(candidateRangeMap::put); return finalFilters.filters.stream() .map(filter -> { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org