fix tx mark end check

hanchuanchuan · Nov 2, 2023 · 330ef20 · 330ef20
1 parent fd1fa9b
commit 330ef20
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/session/parser.go b/session/parser.go
@@ -400,7 +400,6 @@ func (s *session) parserBinlog(ctx context.Context) {
 		}
 
 	ENDCHECK:
-		// 识别到结束标识时退出，正常情况不会读到这里
 		if s.needTransactionMark() {
 			txMark := s.toTransactionMark(e)
 			if txMark != nil && txMark.MarkType == transactionMarkTypeEnd && txMark.LogFile == record.StartFile && txMark.LogPosition == record.StartPosition {
@@ -457,6 +456,9 @@ func (s *session) parserBinlog(ctx context.Context) {
 					s.myRecord = next
 					record = next
 				} else {
+					if s.needTransactionMark() {
+						continue
+					}
 					log.Info("all binlog records processed, exit binlog parser")
 					break
 				}