cdc/api/v2: add missing scheduler config (#8346)

close #8345
pingcap · Feb 23, 2023 · 7427143 · 7427143
1 parent 77d2c22
commit 7427143
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/cdc/api/v2/model.go b/cdc/api/v2/model.go
@@ -387,6 +387,9 @@ func GetDefaultReplicaConfig() *ReplicaConfig {
 			FlushIntervalInMs: config.DefaultFlushIntervalInMs,
 			Storage:           "",
 		},
+		Scheduler: &ChangefeedSchedulerConfig{
+			RegionPerSpan: config.GetDefaultReplicaConfig().Scheduler.RegionPerSpan,
+		},
 	}
 }
 

diff --git a/cdc/api/v2/model_test.go b/cdc/api/v2/model_test.go
@@ -24,6 +24,12 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
+func TestDefaultReplicaConfig(t *testing.T) {
+	t.Parallel()
+	cfg := GetDefaultReplicaConfig()
+	require.NotNil(t, cfg.Scheduler)
+}
+
 func TestToAPIReplicaConfig(t *testing.T) {
 	cfg := config.GetDefaultReplicaConfig()
 	cfg.EnableOldValue = false