[iotdb] branch add-wal-log-in-0.11 created (now 6133c2c)

[xu...@apache.org]

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

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


      at 6133c2c  add wal log

This branch includes the following new commits:

     new 6133c2c  add wal log

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[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-0.11
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 6133c2cbdd89f8888f3e49e0933fbba0a9152227
Author: 151250176 <15...@smail.nju.edu.cn>
AuthorDate: Fri Feb 5 11:29:19 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;
   }