fix query

Signed-off-by: Tim Vaillancourt <tim@timvaillancourt.com>
github · Aug 13, 2024 · 50fb127 · 50fb127
1 parent 4608ffc
commit 50fb127
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/go/logic/applier.go b/go/logic/applier.go
@@ -988,6 +988,7 @@ func (this *Applier) AtomicCutOverMagicLock(sessionIdChan chan int64, tableLocke
 	}
 
 	defer func() {
+		query = fmt.Sprintf(`set /* gh-ost */ session wait_timeout:=%d`, this.migrationContext.ApplierWaitTimeout)
 		if _, err := sqlutils.ExecNoPrepare(this.db, query); err != nil {
 			this.migrationContext.Log.Errorf("Failed to restore applier wait_timeout to %d seconds: %v",
 				this.migrationContext.ApplierWaitTimeout, err,