diff --git a/internal/services/configstore/readdb/readdb.go b/internal/services/configstore/readdb/readdb.go
index b526a6f..6095298 100644
--- a/internal/services/configstore/readdb/readdb.go
+++ b/internal/services/configstore/readdb/readdb.go
@@ -352,6 +352,7 @@ func (r *ReadDB) SyncRDB(ctx context.Context) error {
 		}
 	}
 
+	r.log.Infof("syncing from wals")
 	err = r.rdb.Do(func(tx *db.Tx) error {
 		if err := r.insertRevision(tx, revision); err != nil {
 			return err
@@ -360,21 +361,21 @@ func (r *ReadDB) SyncRDB(ctx context.Context) error {
 		// use the same revision as previous operation
 		for walElement := range r.dm.ListEtcdWals(ctx, revision) {
 			if walElement.Err != nil {
-				return err
+				return walElement.Err
 			}
 			if walElement.WalData.WalSequence <= curWalSeq {
 				continue
 			}
 
-			if err := r.insertCommittedWalSequence(tx, walElement.WalData.WalSequence); err != nil {
-				return err
-			}
-
 			// update readdb only when the wal has been committed to etcd
 			if walElement.WalData.WalStatus != datamanager.WalStatusCommitted {
 				return nil
 			}
 
+			if err := r.insertCommittedWalSequence(tx, walElement.WalData.WalSequence); err != nil {
+				return err
+			}
+
 			r.log.Debugf("applying wal to db")
 			if err := r.applyWal(tx, walElement.WalData.WalDataFileID); err != nil {
 				return err
diff --git a/internal/services/runservice/readdb/readdb.go b/internal/services/runservice/readdb/readdb.go
index de7e1c8..07ab217 100644
--- a/internal/services/runservice/readdb/readdb.go
+++ b/internal/services/runservice/readdb/readdb.go
@@ -602,6 +602,7 @@ func (r *ReadDB) SyncObjectStorage(ctx context.Context) error {
 		}
 	}
 
+	r.log.Infof("syncing from wals")
 	err = r.rdb.Do(func(tx *db.Tx) error {
 		if err := insertRevisionOST(tx, revision); err != nil {
 			return err
@@ -610,21 +611,21 @@ func (r *ReadDB) SyncObjectStorage(ctx context.Context) error {
 		// use the same revision as previous operation
 		for walElement := range r.dm.ListEtcdWals(ctx, revision) {
 			if walElement.Err != nil {
-				return err
+				return walElement.Err
 			}
 			if walElement.WalData.WalSequence <= curWalSeq {
 				continue
 			}
 
-			if err := r.insertCommittedWalSequenceOST(tx, walElement.WalData.WalSequence); err != nil {
-				return err
-			}
-
 			// update readdb only when the wal has been committed to etcd
 			if walElement.WalData.WalStatus != datamanager.WalStatusCommitted {
 				return nil
 			}
 
+			if err := r.insertCommittedWalSequenceOST(tx, walElement.WalData.WalSequence); err != nil {
+				return err
+			}
+
 			r.log.Debugf("applying wal to db")
 			if err := r.applyWal(tx, walElement.WalData.WalDataFileID); err != nil {
 				return err