diff --git a/go/logic/migrator.go b/go/logic/migrator.go
index 7255fc757..714b42f1d 100644
--- a/go/logic/migrator.go
+++ b/go/logic/migrator.go
@@ -1362,7 +1362,9 @@ func (this *Migrator) initiateApplier() error {
 				return err
 			}
 		}
-		this.applier.WriteChangelogState(string(GhostTableMigrated))
+		if _, err := this.applier.WriteChangelogState(string(GhostTableMigrated)); err != nil {
+			return err
+		}
 	}
 
 	// ensure performance_schema.metadata_locks is available.