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 <[email protected]> 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()); }
