From 91793c051c32e3b02fffb1fafd5c123a8fb59e34 Mon Sep 17 00:00:00 2001 From: dongmen <414110582@qq.com> Date: Tue, 31 Dec 2024 17:55:26 +0800 Subject: [PATCH] fix panic Signed-off-by: dongmen <414110582@qq.com> --- maintainer/maintainer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/maintainer/maintainer.go b/maintainer/maintainer.go index 5e2aaa75c..14757b279 100644 --- 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()),