[iotdb] 01/01: add wal log

[xu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xuekaifeng pushed a commit to branch add-wal-log-in-master
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit b2ca8e636a10e77fa805ee050b22429294b8fb75
Author: 151250176 <15...@smail.nju.edu.cn>
AuthorDate: Fri Feb 5 11:31:52 2021 +0800

    add wal log
---
 .../main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java b/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java
index d504cbc..f3d23bc 100644
--- a/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java
+++ b/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java
@@ -92,6 +92,7 @@ public class SingleFileLogReader implements ILogReader {
       fileCorrupted = fileCorrupted || batchLogReader.isFileCorrupted();
     } catch (Exception e) {
       logger.error("Cannot read more PhysicalPlans from {} because", filepath, e);
+      logger.error("Successfully read index is {}", idx);
       fileCorrupted = true;
       return false;
     }
@@ -122,6 +123,7 @@ public class SingleFileLogReader implements ILogReader {
   public void open(File logFile) throws FileNotFoundException {
     close();
     logStream = new DataInputStream(new BufferedInputStream(new FileInputStream(logFile)));
+    logger.info("WAL file: {} size is {}", logFile.getName(), logFile.length());
     this.filepath = logFile.getPath();
     idx = 0;
   }