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 11:13:18 UTC

[iotdb] branch rel/0.11 updated: ignore PathNotExistException in recover and change recover error to warn (#2506)

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

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


The following commit(s) were added to refs/heads/rel/0.11 by this push:
     new 9f06c1a  ignore PathNotExistException in recover and change recover error to warn (#2506)
9f06c1a is described below

commit 9f06c1ac2d6012fe3b5276ad9f668dcdac3ed126
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Sat Jan 16 05:12:55 2021 -0600

    ignore PathNotExistException in recover and change recover error to warn (#2506)
---
 .../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 {