You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2021/01/16 10:43:55 UTC

[iotdb] branch fix_wal_log created (now 537eece)

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

qiaojialin pushed a change to branch fix_wal_log
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


      at 537eece  ignore PathNotExistException in recover and change recover error to warn

This branch includes the following new commits:

     new 537eece  ignore PathNotExistException in recover and change recover error to warn

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: ignore PathNotExistException in recover and change recover error to warn

Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit 537eece5a143fad16bda1eb33ce5afc99cb44662
Author: qiaojialin <64...@qq.com>
AuthorDate: Sat Jan 16 18:43:22 2021 +0800

    ignore PathNotExistException in recover and change recover error to warn
---
 .../main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java b/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
index d2c0a9b5b..bd865a1 100644
--- a/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
+++ b/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
@@ -102,12 +102,14 @@ public class LogReplayer {
           } else if (plan instanceof UpdatePlan) {
             replayUpdate((UpdatePlan) plan);
           }
+        } catch (PathNotExistException ignored) {
+          // can not get path because it is deleted
         } catch (Exception e) {
-          logger.error("recover wal of {} failed", insertFilePath, e);
+          logger.warn("recover wal of {} failed", insertFilePath, e);
         }
       }
     } catch (IOException e) {
-      logger.error("meet error when redo wal of {}", insertFilePath, e);
+      logger.warn("meet error when redo wal of {}", insertFilePath, e);
     } finally {
       logReader.close();
       try {