fix: use NewInsertDataWithFunctionOutputField when importing binlog file (#40741)

zhengbuqian · web-flow · commit 03b63bf982df · 2025-03-19T10:50:14.000+08:00
issue: #40740 Signed-off-by: Buqian Zheng <zhengbuqian@gmail.com>
diff --git a/internal/util/importutilv2/binlog/reader.go b/internal/util/importutilv2/binlog/reader.go
@@ -138,7 +138,7 @@ func (r *reader) readDelete(deltaLogs []string, tsStart, tsEnd uint64) (*storage
 }
 
 func (r *reader) Read() (*storage.InsertData, error) {
-	insertData, err := storage.NewInsertData(r.schema)
+	insertData, err := storage.NewInsertDataWithFunctionOutputField(r.schema)
 	if err != nil {
 		return nil, err
 	}
@@ -192,7 +192,7 @@ OUTER:
 	if len(masks) == 0 { // no data will undergo filtration, return directly
 		return insertData, nil
 	}
-	result, err := storage.NewInsertData(r.schema)
+	result, err := storage.NewInsertDataWithFunctionOutputField(r.schema)
 	if err != nil {
 		return nil, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -138,7 +138,7 @@ func (r reader) readDelete(deltaLogs []string, tsStart, tsEnd uint64) (storage`
`138`	`138`	`}`
`139`	`139`
`140`	`140`	`func (r reader) Read() (storage.InsertData, error) {`
`141`		`- insertData, err := storage.NewInsertData(r.schema)`
	`141`	`+ insertData, err := storage.NewInsertDataWithFunctionOutputField(r.schema)`
`142`	`142`	`if err != nil {`
`143`	`143`	`return nil, err`
`144`	`144`	`}`
`@@ -192,7 +192,7 @@ OUTER:`
`192`	`192`	`if len(masks) == 0 { // no data will undergo filtration, return directly`
`193`	`193`	`return insertData, nil`
`194`	`194`	`}`
`195`		`- result, err := storage.NewInsertData(r.schema)`
	`195`	`+ result, err := storage.NewInsertDataWithFunctionOutputField(r.schema)`
`196`	`196`	`if err != nil {`
`197`	`197`	`return nil, err`
`198`	`198`	`}`