diff --git a/sync_diff_inspector/diff.go b/sync_diff_inspector/diff.go index a5b2a685e..0fc462e2f 100644 --- a/sync_diff_inspector/diff.go +++ b/sync_diff_inspector/diff.go @@ -749,7 +749,9 @@ func (df *Diff) compareRows(ctx context.Context, rangeInfo *splitter.RangeInfo, lastDownstreamData = nil } - dml.sqls = append(dml.sqls, sql) + if df.exportFixSQL { + dml.sqls = append(dml.sqls, sql) + } } dml.rowAdd = rowsAdd dml.rowDelete = rowsDelete