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

Reply via email to