Skip to content

Commit 994459b

Browse files
committed
fix
1 parent fb03dda commit 994459b

File tree

1 file changed

+6
-4
lines changed
  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source

1 file changed

+6
-4
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/SeriesScanUtil.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1043,8 +1043,10 @@ private long tryToPutAllDirectlyOverlappedUnseqPageReadersIntoMergeReader() thro
10431043
if (firstPageReader == null) {
10441044
initFirstPageReader();
10451045
}
1046-
putPageReaderToMergeReader(firstPageReader);
1047-
firstPageReader = null;
1046+
if (!mergeReader.hasNextTimeValuePair()) {
1047+
putPageReaderToMergeReader(firstPageReader);
1048+
firstPageReader = null;
1049+
}
10481050
} while (!mergeReader.hasNextTimeValuePair());
10491051

10501052
/*
@@ -1072,10 +1074,10 @@ private long calculateInitialEndPointTime(long currentReadStopTime) {
10721074
if (orderUtils.isOverlapped(currentReadStopTime, unSeqPageReader.getStatistics())) {
10731075
if (orderUtils.getAscending()) {
10741076
currentReadStopTime =
1075-
Math.max(currentReadStopTime, firstPageReader.getStatistics().getEndTime());
1077+
Math.max(currentReadStopTime, unSeqPageReader.getStatistics().getEndTime());
10761078
} else {
10771079
currentReadStopTime =
1078-
Math.min(currentReadStopTime, firstPageReader.getStatistics().getEndTime());
1080+
Math.min(currentReadStopTime, unSeqPageReader.getStatistics().getEndTime());
10791081
}
10801082
}
10811083
break;

0 commit comments

Comments
 (0)