config: enable merge operator in raftstore-v2 (#6791)

close #6167 Signed-off-by: bufferflies <[email protected]> Co-authored-by: ti-chi-bot[bot] <108142056+ti-chi-bot[bot]@users.noreply.github.com>
tikv · Jul 13, 2023 · 4ab4c1f · 4ab4c1f
1 parent 0cf11aa
commit 4ab4c1f
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 9 deletions.
diff --git a/server/api/hot_status.go b/server/api/hot_status.go
@@ -210,7 +210,7 @@ func (h *hotStatusHandler) GetHotBuckets(w http.ResponseWriter, r *http.Request)
 			ids[i] = id
 		}
 	}
-	stats := h.Handler.GetHotBuckets()
+	stats := h.Handler.GetHotBuckets(ids...)
 	ret := HotBucketsResponse{}
 	for regionID, stats := range stats {
 		ret[regionID] = make([]*HotBucketsItem, len(stats))

diff --git a/server/cluster/cluster_test.go b/server/cluster/cluster_test.go
@@ -1348,7 +1348,6 @@ func TestSyncConfig(t *testing.T) {
 		if v.updated {
 			re.True(switchRaftV2)
 			tc.opt.UseRaftV2()
-			re.EqualValues(0, tc.opt.GetMaxMergeRegionSize())
 			re.EqualValues(512, tc.opt.GetMaxMovableHotPeerSize())
 			success, switchRaftV2 = syncConfig(tc.storeConfigManager, tc.GetStores())
 			re.True(success)

diff --git a/server/config/persist_options.go b/server/config/persist_options.go
@@ -202,13 +202,7 @@ func (o *PersistOptions) SetMaxReplicas(replicas int) {
 }
 
 // UseRaftV2 set some config for raft store v2 by default temporary.
-// todo: remove this after raft store support this.
-// disable merge check
-func (o *PersistOptions) UseRaftV2() {
-	v := o.GetScheduleConfig().Clone()
-	v.MaxMergeRegionSize = 0
-	o.SetScheduleConfig(v)
-}
+func (o *PersistOptions) UseRaftV2() {}
 
 const (
 	maxSnapshotCountKey            = "schedule.max-snapshot-count"

diff --git a/tests/pdctl/hot/hot_test.go b/tests/pdctl/hot/hot_test.go
@@ -283,6 +283,13 @@ func TestHotWithStoreID(t *testing.T) {
 	re.Equal(buckets.GetStats().ReadKeys[0]/interval, item.ReadKeys)
 	re.Equal(buckets.GetStats().WriteBytes[0]/interval, item.WriteBytes)
 	re.Equal(buckets.GetStats().WriteKeys[0]/interval, item.WriteKeys)
+
+	args = []string{"-u", pdAddr, "hot", "buckets", "2"}
+	output, err = pdctl.ExecuteCommand(cmd, args...)
+	re.NoError(err)
+	hotBuckets = api.HotBucketsResponse{}
+	re.NoError(json.Unmarshal(output, &hotBuckets))
+	re.Nil(hotBuckets[2])
 }
 
 func TestHistoryHotRegions(t *testing.T) {