We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 805a121 commit 43b1f58Copy full SHA for 43b1f58
driver/mysql/applier_incr.go
@@ -300,10 +300,7 @@ func (a *ApplierIncr) handleEntry(entryCtx *common.EntryContext) (err error) {
300
// Note: the gtidExecuted will be updated after commit.
301
// For a big-tx, we determine whether to skip for each parts.
302
if skipEntry {
303
- if binlogEntry.Final {
304
- a.EntryExecutedHook(binlogEntry) // make gtid continuous
305
- }
306
-
+ a.EntryExecutedHook(binlogEntry) // make gtid continuous
307
return nil
308
}
309
// endregion
0 commit comments