diff --git a/pkg/vm/engine/tae/logstore/store/store_test.go b/pkg/vm/engine/tae/logstore/store/store_test.go
index a0291a0612c72e24b8cb4a9ae37927bfbf143fa5..cdc93d25326d39abc057bae9b52cc267b0dee8e9 100644
--- a/pkg/vm/engine/tae/logstore/store/store_test.go
+++ b/pkg/vm/engine/tae/logstore/store/store_test.go
@@ -73,9 +73,8 @@ func TestAddrVersion(t *testing.T) {
 	}
 
 	testutils.WaitExpect(4000, func() bool {
-		s.addrmu.RLock()
-		defer s.addrmu.RUnlock()
-		return len(s.addrs[entry.GTUncommit]) == 5
+		t.Log(s.GetSynced(entry.GTUncommit))
+		return s.GetSynced(entry.GTUncommit) == 10
 	})
 	s.addrmu.RLock()
 	defer s.addrmu.RUnlock()
diff --git a/pkg/vm/engine/tae/logstore/store/syncbase.go b/pkg/vm/engine/tae/logstore/store/syncbase.go
index 3469ab9acfe7d78d206d3a1424598364baaafccd..a90aa597af680ee5ab76d6f8c6222130e9a0dec1 100644
--- a/pkg/vm/engine/tae/logstore/store/syncbase.go
+++ b/pkg/vm/engine/tae/logstore/store/syncbase.go
@@ -208,8 +208,8 @@ func (base *syncBase) OnEntryReceived(v *entry.Info) error {
 		}
 		// fmt.Printf("receive uncommit %d-%d\n", v.Group, v.GroupLSN)
 	default:
-		base.syncing[v.Group] = v.GroupLSN
 	}
+	base.syncing[v.Group] = v.GroupLSN
 	base.addrmu.Lock()
 	defer base.addrmu.Unlock()
 	addr := v.Info.(*VFileAddress)