[iotdb] 01/01: Support TimePartiton in mpp query

[ja...@apache.org]

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

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

commit 79367924bf5a5cfbbcaed8cc0e3953ce3151fc3e
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri Aug 5 15:36:48 2022 +0800

    Support TimePartiton in mpp query
---
 .../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());
   }