fix panic

Signed-off-by: dongmen <[email protected]>
pingcap · Dec 31, 2024 · 91793c0 · 91793c0
1 parent 5625f63
commit 91793c0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/maintainer/maintainer.go b/maintainer/maintainer.go
@@ -182,10 +182,10 @@ func NewMaintainer(cfID common.ChangeFeedID,
 		handleEventDuration:            metrics.MaintainerHandleEventDuration.WithLabelValues(cfID.Namespace(), cfID.Name()),
 	}
 
-	m.setWatermark(heartbeatpb.Watermark{
+	m.watermark.Watermark = &heartbeatpb.Watermark{
 		CheckpointTs: checkpointTs,
 		ResolvedTs:   checkpointTs,
-	})
+	}
 	m.state.Store(int32(heartbeatpb.ComponentState_Working))
 	m.bootstrapper = bootstrap.NewBootstrapper[heartbeatpb.MaintainerBootstrapResponse](m.id.Name(), m.getNewBootstrapFn())
 	log.Info("changefeed maintainer is created", zap.String("id", cfID.String()),