void removeUnknownMembers ( ) { ClusterServiceImpl clusterService = node . getClusterService ( ) ; for ( InternalPartitionImpl partition : partitions ) { for ( int i = 0 ; i < InternalPartition . MAX_REPLICA_COUNT ; i ++ ) { PartitionReplica replica = partition . getReplica ( i ) ; if ( replica == null ) { continue ; } if ( clusterService . getMember ( replica . address ( ) , replica . uuid ( ) ) == null ) { partition . setReplica ( i , null ) ; if ( logger . isFinestEnabled ( ) ) { logger . finest ( "PartitionId=" + partition . getPartitionId ( ) + " " + replica + " is removed from replica index: " + i + ", partition: " + partition ) ; } } } } }
Checks all replicas for all partitions . If the cluster service does not contain the member for any address in the partition table it will remove the address from the partition .