fix unit test.

pingcap · Sep 12, 2023 · 956ada2 · 956ada2
1 parent 9f37626
commit 956ada2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/cmd/util/helper_test.go b/pkg/cmd/util/helper_test.go
@@ -191,7 +191,7 @@ func TestAndWriteExampleReplicaTOML(t *testing.T) {
 	err = cfg.ValidateAndAdjust(sinkURL)
 	require.NoError(t, err)
 	require.Equal(t, &config.SinkConfig{
-		EncoderConcurrency: util.AddressOf(16),
+		EncoderConcurrency: util.AddressOf(config.DefaultEncoderGroupConcurrency),
 		DispatchRules: []*config.DispatchRule{
 			{PartitionRule: "ts", TopicRule: "hello_{schema}", Matcher: []string{"test1.*", "test2.*"}},
 			{PartitionRule: "rowid", TopicRule: "{schema}_world", Matcher: []string{"test3.*", "test4.*"}},
@@ -230,7 +230,7 @@ func TestAndWriteStorageSinkTOML(t *testing.T) {
 	require.NoError(t, err)
 	require.Equal(t, &config.SinkConfig{
 		Protocol:                 util.AddressOf(config.ProtocolCanalJSON.String()),
-		EncoderConcurrency:       util.AddressOf(16),
+		EncoderConcurrency:       util.AddressOf(config.DefaultEncoderGroupConcurrency),
 		Terminator:               util.AddressOf(config.CRLF),
 		TxnAtomicity:             util.AddressOf(config.AtomicityLevel("")),
 		DateSeparator:            util.AddressOf("day"),