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 4636a0bc67862626a05ad18b2a7b67caafbac963
Author: qiaojialin <[email protected]>
AuthorDate: Fri Oct 18 17:58:50 2019 +0800

    add log
---
 .../java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

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 4f8654e..91a3685 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
@@ -634,7 +634,12 @@ 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);
+              throw e;
+            }
             currentChunkGroup.setEndOffsetOfChunkGroup(endOffsetOfChunkGroup);
             currentChunkGroup.setVersion(versionOfChunkGroup++);
             newMetaData.add(currentChunkGroup);

Reply via email to