This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch fix_recover_bug in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit a75a5e546d646d2f51ed233ae88dac0435c289e9 Author: qiaojialin <[email protected]> AuthorDate: Fri Oct 18 09:05:24 2019 +0800 add log --- .../java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java index eec73e0..a8cb458 100644 --- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java +++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java @@ -492,7 +492,7 @@ public class TsFileSequenceReader implements AutoCloseable { long endTimeOfChunk = 0; long numOfPoints = 0; - ChunkGroupMetaData currentChunkGroup; + ChunkGroupMetaData currentChunkGroup = null; List<ChunkMetaData> chunks = null; String deviceID; long startOffsetOfChunkGroup = 0; @@ -587,7 +587,11 @@ public class TsFileSequenceReader implements AutoCloseable { ChunkGroupFooter chunkGroupFooter = this.readChunkGroupFooter(); deviceID = chunkGroupFooter.getDeviceID(); endOffsetOfChunkGroup = this.position(); - currentChunkGroup = new ChunkGroupMetaData(deviceID, chunks, startOffsetOfChunkGroup); + try { + currentChunkGroup = new ChunkGroupMetaData(deviceID, chunks, startOffsetOfChunkGroup); + } catch (IllegalArgumentException e) { + logger.error("corrupted tsfile is {}", file); + } currentChunkGroup.setEndOffsetOfChunkGroup(endOffsetOfChunkGroup); currentChunkGroup.setVersion(versionOfChunkGroup++); newMetaData.add(currentChunkGroup);
