This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch wal_compression in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d565d4af5ca2469b53ae7f44f3439410aaec695e Author: OneSizeFitQuorum <[email protected]> AuthorDate: Sat Jun 29 16:09:52 2024 +0800 optimize log Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java index abaf9dce36d..06a677c309b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java @@ -260,14 +260,13 @@ public class WALInputStream extends InputStream implements AutoCloseable { try { loadNextSegmentV2(); version = WALFileVersion.V2; - return; } catch (Throwable e) { // failed to load in V2 way, try in V1 way - logger.warn("Failed to load WAL segment in V2 way, try in V1 way", e); channel.position(originPosition); + loadNextSegmentV1(); + version = WALFileVersion.V1; + logger.info("Failed to load WAL segment in V2 way, try in V1 way successfully."); } - loadNextSegmentV1(); - version = WALFileVersion.V1; } /**
