diff --git a/pkg/cmd/util/helper_test.go b/pkg/cmd/util/helper_test.go index 0d8f98d2360..65efd653437 100644 --- a/pkg/cmd/util/helper_test.go +++ b/pkg/cmd/util/helper_test.go @@ -151,14 +151,14 @@ func TestStrictDecodeInvalidFile(t *testing.T) { configPath := filepath.Join(tmpDir, "ticdc.toml") configContent := fmt.Sprintf(` -unknown = "128.0.0.1:1234" -data-dir = "%+v" - -[log.unkown] -max-size = 200 -max-days = 1 -max-backups = 1 -`, dataDir) + unknown = "128.0.0.1:1234" + data-dir = "%+v" + + [log.unkown] + max-size = 200 + max-days = 1 + max-backups = 1 + `, dataDir) err := os.WriteFile(configPath, []byte(configContent), 0o644) require.Nil(t, err) @@ -191,7 +191,8 @@ func TestAndWriteExampleReplicaTOML(t *testing.T) { {Matcher: []string{"test1.*", "test2.*"}, Columns: []string{"column1", "column2"}}, {Matcher: []string{"test3.*", "test4.*"}, Columns: []string{"!a", "column3"}}, }, - Protocol: "open-protocol", + Protocol: "open-protocol", + TxnAtomicity: config.TableTxnAtomicity, }, cfg.Sink) } diff --git a/tests/integration_tests/big_txn/run.sh b/tests/integration_tests/big_txn/run.sh index 649b4cab9ef..c5f8651388a 100755 --- a/tests/integration_tests/big_txn/run.sh +++ b/tests/integration_tests/big_txn/run.sh @@ -24,7 +24,7 @@ function run() { TOPIC_NAME="ticdc-big-txn-test-$RANDOM" case $SINK_TYPE in kafka) SINK_URI="kafka://127.0.0.1:9092/$TOPIC_NAME?protocol=open-protocol&partition-num=4&kafka-version=${KAFKA_VERSION}&max-message-bytes=10485760" ;; - *) SINK_URI="mysql://normal:123456@127.0.0.1:3306?split-txn=true" ;; + *) SINK_URI="mysql://normal:123456@127.0.0.1:3306?transaction-atomicity=none" ;; esac run_cdc_cli changefeed create --start-ts=$start_ts --sink-uri="$SINK_URI"