Skip to content

Commit 646695b

Browse files
committed
fix bug
1 parent 817ced0 commit 646695b

File tree

1 file changed

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

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1067,7 +1067,7 @@ private long calculateInitialEndPointTime(long currentReadStopTime) {
10671067
Math.max(currentReadStopTime, firstPageReader.getStatistics().getEndTime());
10681068
} else {
10691069
currentReadStopTime =
1070-
Math.min(currentReadStopTime, firstPageReader.getStatistics().getEndTime());
1070+
Math.min(currentReadStopTime, firstPageReader.getStatistics().getStartTime());
10711071
}
10721072
}
10731073
for (IVersionPageReader unSeqPageReader : unSeqPageReaders) {
@@ -1077,7 +1077,7 @@ private long calculateInitialEndPointTime(long currentReadStopTime) {
10771077
Math.max(currentReadStopTime, unSeqPageReader.getStatistics().getEndTime());
10781078
} else {
10791079
currentReadStopTime =
1080-
Math.min(currentReadStopTime, unSeqPageReader.getStatistics().getEndTime());
1080+
Math.min(currentReadStopTime, unSeqPageReader.getStatistics().getStartTime());
10811081
}
10821082
} else {
10831083
break;

0 commit comments

Comments
 (0)