Skip to content

Commit 411d21d

Browse files
author
ffffwh
committed
use DumpEntryLimit also for incr big tx
1 parent 80f4ffe commit 411d21d

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

driver/mysql/binlog/binlog_reader.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -743,8 +743,6 @@ func (b *BinlogReader) handleQueryEvent(ev *replication.BinlogEvent,
743743
const (
744744
dtleQueryPrefix = "/*dtle_gtid1 "
745745
dtleQuerySuffix = " dtle_gtid*/"
746-
747-
bigTxSplittingSize = 64 * 1024 * 1024
748746
)
749747

750748
func (b *BinlogReader) checkDtleQueryOSID(query string) error {
@@ -1974,7 +1972,7 @@ func (b *BinlogReader) handleRowsEvent(ev *replication.BinlogEvent, rowsEvent *r
19741972
b.entryContext.Entry.Events = append(b.entryContext.Entry.Events, *dmlEvent)
19751973
}
19761974

1977-
if b.entryContext.OriginalSize >= bigTxSplittingSize {
1975+
if b.entryContext.OriginalSize >= b.mysqlContext.DumpEntryLimit {
19781976
b.logger.Debug("splitting big tx", "index", b.entryContext.Entry.Index)
19791977
b.entryContext.Entry.Final = false
19801978
b.sendEntry(entriesChannel)

0 commit comments

Comments
 (0)