fix compile error

streamnative · Nov 7, 2024 · 6697e6f · 6697e6f
1 parent 4b9f052
commit 6697e6f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/coordinator/impl/shard_controller.go b/coordinator/impl/shard_controller.go
@@ -894,7 +894,7 @@ func (s *shardController) SyncServerAddress() {
 	s.shardMetadataMutex.RLock()
 	exist := false
 	for _, candidate := range s.shardMetadata.Ensemble {
-		if newInfo, ok := s.coordinator.FindNodeInfoById(candidate.GetNodeId()); ok {
+		if newInfo, ok := s.coordinator.FindServerAddressByInternalAddress(candidate.Internal); ok {
 			if *newInfo != candidate {
 				exist = true
 				break