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: 周沛辰 <[email protected]>
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());
+ }
}
}
}