This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch dev-1.0.1 in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit 7aa29d48fc27a88618fbc08dcd11246c74c1d422 Author: Kikyou1997 <[email protected]> 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 6e435cd54e..d5e0974d62 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 @@ -74,6 +74,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 154f9cfbc2..4670019641 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; @@ -133,7 +138,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: [email protected] For additional commands, e-mail: [email protected]
