[iotdb] branch master updated: Support TimePartiton in mpp query (#6901)

[qi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new ffd346c236 Support TimePartiton in mpp query (#6901)
ffd346c236 is described below

commit ffd346c2361965ca2f44fe5ab24ce15b75bbc055
Author: Jackie Tien <ja...@gmail.com>
AuthorDate: Fri Aug 5 20:12:48 2022 +0800

    Support TimePartiton in mpp query (#6901)
---
 .../src/main/java/org/apache/iotdb/commons/partition/DataPartition.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
index 9523e22482..35e3a98a6f 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
@@ -78,6 +78,7 @@ public class DataPartition extends Partition {
     // TODO: (xingtanzjr) the timePartitionIdList is ignored
     return dataPartitionMap.get(storageGroup).get(seriesPartitionSlot).values().stream()
         .flatMap(Collection::stream)
+        .distinct()
         .collect(Collectors.toList());
   }