Skip to content

Commit fd45779

Browse files
author
ffffwh
committed
fix missing to reduce global big tx counter
It might cause job stuck.
1 parent 3901b78 commit fd45779

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

driver/mysql/extractor.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -1585,7 +1585,7 @@ func (e *Extractor) Shutdown() error {
15851585
e.shutdown = true
15861586
close(e.shutdownCh)
15871587

1588-
if e.binlogReader != nil && atomic.LoadInt32(&e.binlogReader.BigTxCount) > 1 {
1588+
if e.binlogReader != nil && atomic.LoadInt32(&e.binlogReader.BigTxCount) >= 1 {
15891589
g.SubBigTxJob()
15901590
}
15911591

0 commit comments

Comments
 (0)