You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/03/11 08:07:59 UTC
[iotdb] branch master updated: [IOTDB-2721]Fix ChunkReaderTest CI (#5201)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new e31f129 [IOTDB-2721]Fix ChunkReaderTest CI (#5201)
e31f129 is described below
commit e31f129c993508c4a526501cde18dcb2ac8df95d
Author: 周沛辰 <45...@users.noreply.github.com>
AuthorDate: Fri Mar 11 16:07:11 2022 +0800
[IOTDB-2721]Fix ChunkReaderTest CI (#5201)
---
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 28 +++++++++++-----------
1 file changed, 14 insertions(+), 14 deletions(-)
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/ChunkReaderTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/ChunkReaderTest.java
index f53f01b..70606b3 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/ChunkReaderTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/ChunkReaderTest.java
@@ -88,20 +88,20 @@ public class ChunkReaderTest {
@Test
public void testAccelerateQueryByTimestamp() throws IOException {
- TsFileSequenceReader tsFileSequenceReader = new TsFileSequenceReader(file.getPath());
-
- for (int i = 0; i < deviceNum; i++) {
- for (int j = 0; j < measurementNum; j++) {
- List<ChunkMetadata> chunkMetadataList =
- tsFileSequenceReader.getChunkMetadataList(
- new Path(testStorageGroup + PATH_SEPARATOR + "d" + i, "s" + j));
- for (ChunkMetadata chunkMetadata : chunkMetadataList) {
- Chunk chunk = tsFileSequenceReader.readMemChunk(chunkMetadata);
- ChunkReader chunkReader = new ChunkReader(chunk, null);
- chunk = tsFileSequenceReader.readMemChunk(chunkMetadata);
- ChunkReader chunkReaderByTimestamp = new ChunkReader(chunk, null, 301);
- Assert.assertEquals(5, chunkReader.loadPageReaderList().size());
- Assert.assertEquals(2, chunkReaderByTimestamp.loadPageReaderList().size());
+ try (TsFileSequenceReader tsFileSequenceReader = new TsFileSequenceReader(file.getPath())) {
+ for (int i = 0; i < deviceNum; i++) {
+ for (int j = 0; j < measurementNum; j++) {
+ List<ChunkMetadata> chunkMetadataList =
+ tsFileSequenceReader.getChunkMetadataList(
+ new Path(testStorageGroup + PATH_SEPARATOR + "d" + i, "s" + j));
+ for (ChunkMetadata chunkMetadata : chunkMetadataList) {
+ Chunk chunk = tsFileSequenceReader.readMemChunk(chunkMetadata);
+ ChunkReader chunkReader = new ChunkReader(chunk, null);
+ chunk = tsFileSequenceReader.readMemChunk(chunkMetadata);
+ ChunkReader chunkReaderByTimestamp = new ChunkReader(chunk, null, 301);
+ Assert.assertEquals(5, chunkReader.loadPageReaderList().size());
+ Assert.assertEquals(2, chunkReaderByTimestamp.loadPageReaderList().size());
+ }
}
}
}