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 {