Skip to content

Commit

Permalink
fix tmp bug
Browse files Browse the repository at this point in the history
  • Loading branch information
qiaojialin committed Mar 2, 2020
1 parent 23d620a commit 3954860
Showing 1 changed file with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -306,9 +306,9 @@ private boolean hasNextOverlappedPage() throws IOException {
return true;
}

while (true) {
tryToPutAllDirectlyOverlappedPageReadersIntoMergeReader();

tryToPutAllDirectlyOverlappedPageReadersIntoMergeReader();
while (true) {

if (mergeReader.hasNextTimeValuePair()) {

Expand All @@ -331,13 +331,15 @@ private boolean hasNextOverlappedPage() throws IOException {
unpackAllOverlappedChunkMetadataToCachedPageReaders(timeValuePair.getTimestamp());
unpackAllOverlappedCachedPageReadersToMergeReader(timeValuePair.getTimestamp());

timeValuePair = mergeReader.nextTimeValuePair();

if (valueFilter == null || valueFilter
.satisfy(timeValuePair.getTimestamp(), timeValuePair.getValue().getValue())) {
cachedBatchData.putAnObject(
timeValuePair.getTimestamp(), timeValuePair.getValue().getValue());
}

mergeReader.nextTimeValuePair();
// mergeReader.nextTimeValuePair();

}
hasCachedNextOverlappedPage = cachedBatchData.hasCurrent();
Expand Down

0 comments on commit 3954860

Please sign in to comment.