[iotdb] 04/04: revert log for wal debug

[xi...@apache.org]

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

xingtanzjr pushed a commit to branch ml_0815_data_lost
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 9f2fdf52a7ec2bf5df5d67db6543a327320ad1db
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Aug 19 11:24:17 2022 +0800

    revert log for wal debug
---
 .../org/apache/iotdb/db/wal/recover/WALNodeRecoverTask.java  | 12 ------------
 1 file changed, 12 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/wal/recover/WALNodeRecoverTask.java b/server/src/main/java/org/apache/iotdb/db/wal/recover/WALNodeRecoverTask.java
index 1bb9cc66ff..d5a13e2596 100644
--- a/server/src/main/java/org/apache/iotdb/db/wal/recover/WALNodeRecoverTask.java
+++ b/server/src/main/java/org/apache/iotdb/db/wal/recover/WALNodeRecoverTask.java
@@ -181,7 +181,6 @@ public class WALNodeRecoverTask implements Runnable {
   }
 
   private void recoverInfoFromCheckpoints() {
-    logger.error("logDirectory is {}", logDirectory.getAbsolutePath());
     // parse memTables information
     CheckpointRecoverUtils.CheckpointInfo info =
         CheckpointRecoverUtils.recoverMemTableInfo(logDirectory);
@@ -197,7 +196,6 @@ public class WALNodeRecoverTask implements Runnable {
       }
     }
     // update firstValidVersionId and get recover performer from WALRecoverManager
-    logger.error("memTableId2Info size {}", memTableId2Info.values().size());
     for (MemTableInfo memTableInfo : memTableId2Info.values()) {
       firstValidVersionId = Math.min(firstValidVersionId, memTableInfo.getFirstFileVersionId());
 
@@ -211,8 +209,6 @@ public class WALNodeRecoverTask implements Runnable {
 
   private void recoverTsFiles() {
     if (memTableId2RecoverPerformer.isEmpty()) {
-      logger.error(
-          "memTableId2RecoverPerformer is empty. {}", memTableId2RecoverPerformer.values());
       return;
     }
     // make preparation for recovery
@@ -235,15 +231,12 @@ public class WALNodeRecoverTask implements Runnable {
     // asc sort by version id
     WALFileUtils.ascSortByVersionId(walFiles);
     // read .wal files and redo logs
-    int entryIndex = 0;
-    int successIndex = 0;
     for (int i = 0; i < walFiles.length; ++i) {
       File walFile = walFiles[i];
       // last wal file may corrupt
       try (WALReader walReader = new WALReader(walFile, i == walFiles.length - 1)) {
         while (walReader.hasNext()) {
           WALEntry walEntry = walReader.next();
-          logger.error("Recover one Entry. File index: {}. Index: {}", i, entryIndex++);
           if (!memTableId2Info.containsKey(walEntry.getMemTableId())) {
             continue;
           }
@@ -252,7 +245,6 @@ public class WALNodeRecoverTask implements Runnable {
               memTableId2RecoverPerformer.get(walEntry.getMemTableId());
           if (recoverPerformer != null) {
             recoverPerformer.redoLog(walEntry);
-            logger.error("Redo an Entry. File index: {}. Index: {} ", i, successIndex++);
           } else {
             logger.warn(
                 "Fail to find TsFile recover performer for wal entry in TsFile {}", walFile);
@@ -267,13 +259,9 @@ public class WALNodeRecoverTask implements Runnable {
       try {
         recoverPerformer.endRecovery();
         recoverPerformer.getRecoverListener().succeed();
-
       } catch (Exception e) {
         recoverPerformer.getRecoverListener().fail(e);
       }
-      File fileAfterRecovered = new File(recoverPerformer.getTsFileAbsolutePath());
-      logger.error(
-          "Recover file: {}, size = {}", fileAfterRecovered.getName(), fileAfterRecovered.length());
     }
   }
 }