This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch firstChunk in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a05ed2e71d01da761a9164cefe71f2416975f1c2 Author: Xiangwei Wei <[email protected]> AuthorDate: Thu Jan 21 21:19:33 2021 +0800 first chunkmetadata should be consumed first (#2547) first chunkmetadata should be consumed first --- .../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();
