diff --git a/go/logic/migrator.go b/go/logic/migrator.go index 17977ee0c..5e1be578e 100644 --- a/go/logic/migrator.go +++ b/go/logic/migrator.go @@ -980,6 +980,7 @@ func (mgtr *Migrator) resumeMoveTablesCutOverFromCheckpoint(chk *Checkpoint) err } atomic.StoreInt64(&mgtr.migrationContext.CutOverCompleteFlag, 1) mgtr.migrationContext.Log.Debugf("T4: CutOverCompleteFlag set") + mgtr.migrationContext.MoveTables.DrainGTID = chk.MoveTablesCutOverDrainGTID if err := mgtr.hooksExecutor.OnSuccess(false); err != nil { return fmt.Errorf("on-success hook failed: %w", err) }