From db9a73f85045c00bec3d055d4c3cbcc8cce6983f Mon Sep 17 00:00:00 2001
From: lisijia <348290933@qq.com>
Date: Wed, 8 Sep 2021 16:08:58 +0800
Subject: [PATCH] [IOTDB-1619] There is an error msg when I restart
 iotdb-cluster

---
 .../log/manage/serializable/SyncLogDequeSerializer.java  | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java b/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java
index c81e6d051ee09..87f2c8bd4cb1e 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java
@@ -450,11 +450,6 @@ private void initMetaAndLogFiles() {
     this.firstLogIndex = meta.getCommitLogIndex() + 1;
     try {
       recoverLogFiles();
-
-      logDataFileList.sort(this::comparePersistLogFileName);
-
-      logIndexFileList.sort(this::comparePersistLogFileName);
-
       // add init log file
       if (logDataFileList.isEmpty()) {
         createNewLogFile(metaFile.getParentFile().getPath(), meta.getCommitLogIndex() + 1);
@@ -473,6 +468,10 @@ private void recoverLogFiles() {
     // 2. recover the log data file
     recoverLogFiles(LOG_DATA_FILE_SUFFIX);
 
+    // sort by name before recover
+    logDataFileList.sort(this::comparePersistLogFileName);
+    logIndexFileList.sort(this::comparePersistLogFileName);
+
     // 3. recover the last log file in case of abnormal exit
     recoverTheLastLogFile();
   }