This is an automated email from the ASF dual-hosted git repository.
leirui pushed a commit to branch research/M4-visualization
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/research/M4-visualization by
this push:
new 22f407dcb3 add
22f407dcb3 is described below
commit 22f407dcb3820a29215073e543fcdb131f0bfe7f
Author: Lei Rui <[email protected]>
AuthorDate: Thu Apr 13 13:48:39 2023 +0800
add
---
.../java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git
a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java
b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java
index 59ba46ed2c..0834348a26 100644
---
a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java
+++
b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java
@@ -503,14 +503,17 @@ public class ChunkSuit4CPV {
// search from estimatePos in the timeBuffer to find the closet
timestamp equal to or smaller
// than the given timestamp
int estimatedPos = -1;
+ boolean flag = false;
pageReader.timeBuffer.position(0);
pageReader.valueBuffer.position(pageReader.timeBufferLength);
while (pageReader.timeBuffer.remaining() > 0) {
- estimatedPos++;
- IOMonitor.incPointsTravered();
+ if (!flag) {
+ estimatedPos++;
+ IOMonitor.incPointsTravered();
+ }
long t = pageReader.timeBuffer.getLong();
if (t >= targetTimestamp) {
- break;
+ flag = true;
}
}