From 5ddcbbcdaeb4ce6d0f8602487d4c1425db227e6e Mon Sep 17 00:00:00 2001
From: Mengxian Li <ranylmx@gmail.com>
Date: Thu, 14 Aug 2025 15:39:23 -0700
Subject: [PATCH] Not to include fix sqls for disk write when exportFixSQL is
 false

---
 sync_diff_inspector/diff.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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