diff --git a/br/pkg/task/stream.go b/br/pkg/task/stream.go index b2814cd8ae3ad..b63110431ca06 100644 --- a/br/pkg/task/stream.go +++ b/br/pkg/task/stream.go @@ -639,7 +639,7 @@ func RunStreamStop( if err := streamMgr.setGCSafePoint(ctx, utils.BRServiceSafePoint{ ID: buildPauseSafePointName(ti.Info.Name), - TTL: 0, + TTL: utils.DefaultStreamStartSafePointTTL, BackupTS: 0, }, ); err != nil { @@ -693,7 +693,7 @@ func RunStreamPause( utils.BRServiceSafePoint{ ID: buildPauseSafePointName(ti.Info.Name), TTL: cfg.SafePointTTL, - BackupTS: globalCheckPointTS - 1, + BackupTS: globalCheckPointTS, }, ); err != nil { return errors.Trace(err) @@ -766,7 +766,7 @@ func RunStreamResume( if err := streamMgr.setGCSafePoint(ctx, utils.BRServiceSafePoint{ ID: buildPauseSafePointName(ti.Info.Name), - TTL: 0, + TTL: utils.DefaultStreamStartSafePointTTL, BackupTS: globalCheckPointTS, }, ); err != nil {