From 26ac59f1271cde5b4bdbcdb2c7c66b74ea985be9 Mon Sep 17 00:00:00 2001 From: Daniel Joos Date: Mon, 22 Jun 2026 15:12:00 +0200 Subject: [PATCH] Set drain-gtid when resuming in move-tables mode --- go/logic/migrator.go | 1 + 1 file changed, 1 insertion(+) 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) }