fix big txn

pingcap · Jun 28, 2022 · f0a3057 · f0a3057
1 parent dacf4c4
commit f0a3057
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 10 deletions.
diff --git 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
@@ -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:[email protected]:3306?split-txn=true" ;;
+	*) SINK_URI="mysql://normal:[email protected]:3306?transaction-atomicity=none" ;;
 	esac
 	run_cdc_cli changefeed create --start-ts=$start_ts --sink-uri="$SINK_URI"