Fix logs

Signed-off-by: Noble Mittal <[email protected]>
vitessio · Feb 18, 2025 · b40d3eb · b40d3eb
1 parent 5b317c5
commit b40d3eb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/go/vt/vttablet/tabletmanager/vreplication/utils.go b/go/vt/vttablet/tabletmanager/vreplication/utils.go
@@ -52,6 +52,8 @@ const (
 	LogMessage = "Message"
 	// LogCopyStart is used when the copy phase is started.
 	LogCopyStart = "Started Copy Phase"
+	// LogCopyRestart is used when the copy phase is restarted.
+	LogCopyRestart = "Restarted Copy Phase"
 	// LogCopyEnd is used when the copy phase is done.
 	LogCopyEnd = "Ended Copy Phase"
 	// LogStateChange is used when the state of the stream changes.

diff --git a/go/vt/vttablet/tabletmanager/vreplication/vreplicator.go b/go/vt/vttablet/tabletmanager/vreplication/vreplicator.go
@@ -310,6 +310,7 @@ func (vr *vreplicator) replicate(ctx context.Context) error {
 						vr.stats.ErrorCounts.Add([]string{"Copy"}, 1)
 						return err
 					}
+					vr.insertLog(LogCopyRestart, fmt.Sprintf("Copy phase restarted for %d table(s)", numTablesToCopy))
 				}
 				if err := newVCopier(vr).copyNext(ctx, settings); err != nil {
 					vr.stats.ErrorCounts.Add([]string{"Copy"}, 1)