porting change(b62be9d) from release-v3 branch

bifromqio · Jan 24, 2025 · 4f35e5b · 4f35e5b
1 parent 6d88bb0
commit 4f35e5b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...base-kv-store-client/src/main/java/com/baidu/bifromq/basekv/client/BaseKVStoreClient.java b/...base-kv-store-client/src/main/java/com/baidu/bifromq/basekv/client/BaseKVStoreClient.java
@@ -55,6 +55,7 @@
 import com.baidu.bifromq.basekv.store.proto.ReplyCode;
 import com.baidu.bifromq.basekv.store.proto.TransferLeadershipReply;
 import com.baidu.bifromq.basekv.store.proto.TransferLeadershipRequest;
+import com.baidu.bifromq.basekv.utils.BoundaryUtil;
 import com.baidu.bifromq.basekv.utils.DescriptorUtil;
 import com.baidu.bifromq.basekv.utils.KeySpaceDAG;
 import com.baidu.bifromq.baserpc.BluePrint;
@@ -76,6 +77,7 @@
 import java.util.NavigableMap;
 import java.util.Optional;
 import java.util.Set;
+import java.util.TreeMap;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.stream.IntStream;
@@ -106,7 +108,7 @@ private record ClusterInfo(Map<String, KVRangeStoreDescriptor> storeDescriptors,
     private final Subject<Map<String, String>> storeToServerSubject = BehaviorSubject.createDefault(Maps.newHashMap());
     private final Observable<ClusterInfo> clusterInfoObservable;
     private final BehaviorSubject<NavigableMap<Boundary, KVRangeSetting>> effectiveRouterSubject =
-        BehaviorSubject.createDefault(emptyNavigableMap());
+        BehaviorSubject.createDefault(new TreeMap<>(BoundaryUtil::compare));
 
     // key: serverId, val: storeId
     private volatile Map<String, String> serverToStoreMap = Maps.newHashMap();