update test

cdc/sink/dmlsink/txn/mysql/dml_test.go

@@ -18,7 +18,9 @@ import (
 
 	"github.com/pingcap/tidb/pkg/parser/charset"
 	"github.com/pingcap/tidb/pkg/parser/mysql"
+	"github.com/pingcap/tidb/pkg/types"
 	"github.com/pingcap/tiflow/cdc/model"
+	"github.com/pingcap/tiflow/pkg/util"
 	"github.com/stretchr/testify/require"
 )
 
@@ -709,6 +711,23 @@ func TestMapReplace(t *testing.T) {
 				[]byte("你好,世界"),
 			},
 		},
+		{
+			quoteTable: "`test`.`t1`",
+			cols: []*model.Column{
+				{
+					Name:  "a",
+					Type:  mysql.TypeTiDBVectorFloat32,
+					Value: util.Must(types.ParseVectorFloat32("[1.0,-2,0.3,-4.4,55]")),
+				},
+				{
+					Name:  "b",
+					Type:  mysql.TypeTiDBVectorFloat32,
+					Value: util.Must(types.ParseVectorFloat32("[1,2,3,4,5]")),
+				},
+			},
+			expectedQuery: "REPLACE INTO `test`.`t1` (`a`,`b`) VALUES ",
+			expectedArgs:  []interface{}{"[1,-2,0.3,-4.4,55]", "[1,2,3,4,5]"},
+		},
 	}
 	for _, tc := range testCases {
 		// multiple times to verify the stability of column sequence in query string

cdc/sink/dmlsink/txn/mysql/mysql_test.go

@@ -1492,56 +1492,17 @@ func TestPrepareBatchDMLs(t *testing.T) {
 					}}, tableInfoWithVector),
 					ApproximateDataSize: 10,
 				},
-				{
-					StartTs:   418658114257813516,
-					CommitTs:  418658114257813517,
-					TableInfo: tableInfoWithVector,
-					PreColumns: model.Columns2ColumnDatas([]*model.Column{{
-						Name:  "a1",
-						Value: 1,
-					}, {
-						Name:  "a3",
-						Value: util.Must(types.ParseVectorFloat32("[1,2,3,4,5]")),
-					}}, tableInfoWithVector),
-					Columns: model.Columns2ColumnDatas([]*model.Column{{
-						Name:  "a1",
-						Value: 3,
-					}, {
-						Name:  "a3",
-						Value: util.Must(types.ParseVectorFloat32("[1.1,-2,3.33,-4.12,-5]")),
-					}}, tableInfoWithVector),
-					ApproximateDataSize: 10,
-				},
-				{
-					StartTs:   418658114257813516,
-					CommitTs:  418658114257813517,
-					TableInfo: tableInfoWithVector,
-					PreColumns: model.Columns2ColumnDatas([]*model.Column{{
-						Name:  "a1",
-						Value: 3,
-					}, {
-						Name:  "a3",
-						Value: util.Must(types.ParseVectorFloat32("[1.1,-2,3.33,-4.12,-5]")),
-					}}, tableInfoWithVector),
-					ApproximateDataSize: 10,
-				},
 			},
 			expected: &preparedDMLs{
 				startTs: []model.Ts{418658114257813516},
 				sqls: []string{
-					"DELETE FROM `common_1`.`uk_without_pk` WHERE (`a1` = ? AND `a3` = ?)",
-					"UPDATE `common_1`.`uk_without_pk` SET `a1`=CASE WHEN " +
-						"`a1` = ? AND `a3` = ? THEN ? END, `a3`=CASE WHEN " +
-						"`a1` = ? AND `a3` = ? THEN ? END WHERE (`a1` = ? AND `a3` = ?)",
 					"INSERT INTO `common_1`.`uk_without_pk` (`a1`,`a3`) VALUES (?,?)",
 				},
 				values: [][]interface{}{
-					{3, "[1.1,-2,3.33,-4.12,-5]"},
-					{1, "[1,2,3,4,5]", 3, 1, "[1,2,3,4,5]", "[1.1,-2,3.33,-4.12,-5]", 1, "[1,2,3,4,5]"},
 					{1, "[1,2,3,4,5]"},
 				},
-				rowCount:        3,
-				approximateSize: 325,
+				rowCount:        1,
+				approximateSize: 73,
 			},
 		},
 	}

scripts/download-integration-test-binaries.sh

@@ -141,7 +141,7 @@ function download_binaries() {
 	tiflash_download_url="${file_server_url}/download/builds/pingcap/tiflash/${tiflash_branch}/${tiflash_sha1}/centos7/tiflash.tar.gz"
 	minio_download_url="${file_server_url}/download/minio.tar.gz"
 	go_ycsb_download_url="${file_server_url}/download/builds/pingcap/go-ycsb/test-br/go-ycsb"
-	etcd_download_url="${file_server_url}/download/builds/pingcap/cdc/etcd-v3.4.7-linux-amd64.tar.gz"
+	etcd_download_url="${file_server_url}/download/builds/pingcap/cdc/etcd-v3.5.15-linux-amd64.tar.gz"
 	sync_diff_inspector_url="${file_server_url}/download/builds/pingcap/cdc/sync_diff_inspector_hash-a129f096_linux-amd64.tar.gz"
 	jq_download_url="${file_server_url}/download/builds/pingcap/test/jq-1.6/jq-linux64"
 	schema_registry_url="${file_server_url}/download/builds/pingcap/cdc/schema-registry.tar.gz"