ticdc: fix ddl exchange partition xxxx with validation to deal with…

… `with validation` correctly (pingcap#10867) (pingcap#10868) close pingcap#10859
ti-chi-bot · Apr 2, 2024 · 85535a2 · 85535a2
1 parent 06ec4a6
commit 85535a2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/cdc/model/sink.go b/cdc/model/sink.go
@@ -757,6 +757,10 @@ func (d *DDLEvent) FromJobWithArgs(
 		d.Query = fmt.Sprintf("ALTER TABLE `%s`.`%s` EXCHANGE PARTITION `%s` WITH TABLE `%s`.`%s`",
 			tableInfo.TableName.Schema, tableInfo.TableName.Table, partName,
 			preTableInfo.TableName.Schema, preTableInfo.TableName.Table)
+
+		if strings.HasSuffix(upperQuery, "WITHOUT VALIDATION") {
+			d.Query += " WITHOUT VALIDATION"
+		}
 	default:
 		d.Query = job.Query
 	}