From 956ada291c953122d93090e9ae229bcfa0fb3fe0 Mon Sep 17 00:00:00 2001 From: 3AceShowHand Date: Tue, 12 Sep 2023 17:03:04 +0800 Subject: [PATCH] fix unit test. --- pkg/cmd/util/helper_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/cmd/util/helper_test.go b/pkg/cmd/util/helper_test.go index 07149f7cf03..3fdb15544f2 100644 --- 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"),