Skip to content

Commit 59cee44

Browse files
committed
fix
1 parent c765e88 commit 59cee44

File tree

1 file changed

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

1 file changed

+11
-10
lines changed

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

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1060,40 +1060,41 @@ private long tryToPutAllDirectlyOverlappedUnseqPageReadersIntoMergeReader() thro
10601060
return calculateInitialEndPointTime(mergeReaderStopTime);
10611061
}
10621062

1063-
private long calculateInitialEndPointTime(long currentReadStopTime) {
1063+
private long calculateInitialEndPointTime(final long currentReadStopTime) {
1064+
long initialReadStopTime = currentReadStopTime;
10641065
if (firstPageReader != null
10651066
&& !firstPageReader.isSeq()
10661067
&& orderUtils.isOverlapped(currentReadStopTime, firstPageReader.getStatistics())) {
10671068
if (orderUtils.getAscending()) {
1068-
currentReadStopTime =
1069+
initialReadStopTime =
10691070
Math.max(
1070-
currentReadStopTime,
1071+
initialReadStopTime,
10711072
orderUtils.getOverlapCheckTime(firstPageReader.getStatistics()));
10721073
} else {
1073-
currentReadStopTime =
1074+
initialReadStopTime =
10741075
Math.min(
1075-
currentReadStopTime,
1076+
initialReadStopTime,
10761077
orderUtils.getOverlapCheckTime(firstPageReader.getStatistics()));
10771078
}
10781079
}
10791080
for (IVersionPageReader unSeqPageReader : unSeqPageReaders) {
10801081
if (orderUtils.isOverlapped(currentReadStopTime, unSeqPageReader.getStatistics())) {
10811082
if (orderUtils.getAscending()) {
1082-
currentReadStopTime =
1083+
initialReadStopTime =
10831084
Math.max(
1084-
currentReadStopTime,
1085+
initialReadStopTime,
10851086
orderUtils.getOverlapCheckTime(unSeqPageReader.getStatistics()));
10861087
} else {
1087-
currentReadStopTime =
1088+
initialReadStopTime =
10881089
Math.min(
1089-
currentReadStopTime,
1090+
initialReadStopTime,
10901091
orderUtils.getOverlapCheckTime(unSeqPageReader.getStatistics()));
10911092
}
10921093
} else {
10931094
break;
10941095
}
10951096
}
1096-
return currentReadStopTime;
1097+
return initialReadStopTime;
10971098
}
10981099

10991100
private void addTimeValuePairToResult(TimeValuePair timeValuePair, TsBlockBuilder builder) {

0 commit comments

Comments
 (0)