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

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


The following commit(s) were added to refs/heads/rel/0.11 by this push:
     new 8e0ed67  first chunkmetadata should be consumed first (#2547) (#2589)
8e0ed67 is described below

commit 8e0ed67936ddf70198537a9f7cfadcd8288a7c9f
Author: Haonan <[email protected]>
AuthorDate: Wed Jan 27 15:37:25 2021 +0800

    first chunkmetadata should be consumed first (#2547) (#2589)
---
 .../org/apache/iotdb/db/query/reader/series/SeriesReader.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReader.java
 
b/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReader.java
index b433bae..297d57b 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReader.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReader.java
@@ -448,15 +448,15 @@ public class SeriesReader {
 
   private void unpackAllOverlappedChunkMetadataToCachedPageReaders(long 
endpointTime, boolean init)
       throws IOException {
-    while (!cachedChunkMetadata.isEmpty() &&
-        orderUtils.isOverlapped(endpointTime, 
cachedChunkMetadata.peek().getStatistics())) {
-      unpackOneChunkMetaData(cachedChunkMetadata.poll());
-    }
     if (firstChunkMetadata != null &&
         orderUtils.isOverlapped(endpointTime, 
firstChunkMetadata.getStatistics())) {
       unpackOneChunkMetaData(firstChunkMetadata);
       firstChunkMetadata = null;
     }
+    while (!cachedChunkMetadata.isEmpty() &&
+        orderUtils.isOverlapped(endpointTime, 
cachedChunkMetadata.peek().getStatistics())) {
+      unpackOneChunkMetaData(cachedChunkMetadata.poll());
+    }
     if (init && firstPageReader == null && (!seqPageReaders.isEmpty() || 
!unSeqPageReaders
         .isEmpty())) {
       initFirstPageReader();

Reply via email to