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:56 UTC
[iotdb] 01/01: ignore PathNotExistException in recover and change
recover error to warn
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 {