From 85535a21b1786d1e7b462095f48086bc964b8e54 Mon Sep 17 00:00:00 2001
From: Ti Chi Robot <ti-community-prow-bot@tidb.io>
Date: Tue, 2 Apr 2024 09:49:47 +0800
Subject: [PATCH] ticdc: fix ddl `exchange partition xxxx with validation` to
 deal with `with validation` correctly (#10867) (#10868)

close pingcap/tiflow#10859
---
 cdc/model/sink.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/cdc/model/sink.go b/cdc/model/sink.go
index 6ea9234ee7d..42542345337 100644
--- 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
 	}