[iotdb] branch master updated: Add more detailed log for better tracing (#2636)

[hx...@apache.org]

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

hxd 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 c5d48cf  Add more detailed log for better tracing (#2636)
c5d48cf is described below

commit c5d48cfeed2a14067fe80507791f2fe54ac66ef3
Author: SilverNarcissus <15...@smail.nju.edu.cn>
AuthorDate: Fri Feb 5 20:27:39 2021 -0600

    Add more detailed log for better tracing (#2636)
---
 .../java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java    | 6 ++++--
 .../java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java   | 5 ++++-
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
index c643f59..aaf27ff 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
@@ -85,10 +85,12 @@ public class MemTableFlushTask {
    */
   public void syncFlushMemTable()
       throws ExecutionException, InterruptedException {
-    LOGGER.info("The memTable size of SG {} is {}, the avg series points num in chunk is {} ",
+    LOGGER.info(
+        "The memTable size of SG {} is {}, the avg series points num in chunk is {}, total timeseries number is {}",
         storageGroup,
         memTable.memSize(),
-        memTable.getTotalPointsNum() / memTable.getSeriesNumber());
+        memTable.getTotalPointsNum() / memTable.getSeriesNumber(),
+        memTable.getSeriesNumber());
 
     long estimatedTemporaryMemSize = 0L;
     if (config.isEnableMemControl() && SystemInfo.getInstance().isEncodingFasterThanIo()) {
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..f11f158 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
@@ -91,7 +91,9 @@ public class SingleFileLogReader implements ILogReader {
       batchLogReader = new BatchLogReader(ByteBuffer.wrap(buffer));
       fileCorrupted = fileCorrupted || batchLogReader.isFileCorrupted();
     } catch (Exception e) {
-      logger.error("Cannot read more PhysicalPlans from {} because", filepath, e);
+      logger.error(
+          "Cannot read more PhysicalPlans from {}, successfully read index is {}. The reason is",
+          idx, filepath, e);
       fileCorrupted = true;
       return false;
     }
@@ -122,6 +124,7 @@ public class SingleFileLogReader implements ILogReader {
   public void open(File logFile) throws FileNotFoundException {
     close();
     logStream = new DataInputStream(new BufferedInputStream(new FileInputStream(logFile)));
+    logger.info("open WAL file: {} size is {}", logFile.getName(), logFile.length());
     this.filepath = logFile.getPath();
     idx = 0;
   }