You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by li...@apache.org on 2021/01/18 12:51:10 UTC
[iotdb] branch master updated: ignore PathNotExistException in
recover and change recover error to warn (#2506) (#2512)
This is an automated email from the ASF dual-hosted git repository.
liudw 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 d267d10 ignore PathNotExistException in recover and change recover error to warn (#2506) (#2512)
d267d10 is described below
commit d267d10fef67ddfe57545f1bb6811c6fb85ce766
Author: Steve Yurong Su <st...@outlook.com>
AuthorDate: Mon Jan 18 20:50:46 2021 +0800
ignore PathNotExistException in recover and change recover error to warn (#2506) (#2512)
Co-authored-by: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
---
.../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 7ed64ca..0e3b5f1 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
@@ -95,12 +95,14 @@ public class LogReplayer {
} else if (plan instanceof DeletePlan) {
replayDelete((DeletePlan) 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 {