This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 7e88b37c40a [pick](nereids)temporary partition is always pruned #27636
(#27722)
7e88b37c40a is described below
commit 7e88b37c40a95f03e39799325b4c0f50cdf35548
Author: minghong <[email protected]>
AuthorDate: Wed Nov 29 02:58:23 2023 +0800
[pick](nereids)temporary partition is always pruned #27636 (#27722)
---
.../src/main/java/org/apache/doris/catalog/PartitionInfo.java | 10 ++++++++++
.../doris/nereids/rules/expression/rules/PartitionPruner.java | 2 +-
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/catalog/PartitionInfo.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/PartitionInfo.java
index 6bd4604471a..a8033b788f1 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/PartitionInfo.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/PartitionInfo.java
@@ -116,6 +116,16 @@ public class PartitionInfo implements Writable {
}
}
+ /**
+ * @return both normal partition and temp partition
+ */
+ public Map<Long, PartitionItem> getAllPartitions() {
+ HashMap all = new HashMap<>();
+ all.putAll(idToTempItem);
+ all.putAll(idToItem);
+ return all;
+ }
+
public PartitionItem getItem(long partitionId) {
PartitionItem item = idToItem.get(partitionId);
if (item == null) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/PartitionPruner.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/PartitionPruner.java
index 6c932f558b0..a0336295476 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/PartitionPruner.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/PartitionPruner.java
@@ -103,7 +103,7 @@ public class PartitionPruner extends
DefaultExpressionRewriter<Void> {
*/
public static List<Long> prune(List<Slot> partitionSlots, Expression
partitionPredicate,
PartitionInfo partitionInfo, CascadesContext cascadesContext,
PartitionTableType partitionTableType) {
- return prune(partitionSlots, partitionPredicate,
partitionInfo.getIdToItem(false), cascadesContext,
+ return prune(partitionSlots, partitionPredicate,
partitionInfo.getAllPartitions(), cascadesContext,
partitionTableType);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
