Skip to content

Commit

Permalink
address comment
Browse files Browse the repository at this point in the history
  • Loading branch information
lichunzhu committed May 29, 2023
1 parent 6367f58 commit 19e727c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion drainer/safepoint.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ const (
func updateServiceSafePoint(ctx context.Context, pdClient pd.Client, cpt checkpoint.CheckPoint, ttl int64) {
updateInterval := time.Duration(ttl/2) * time.Second
tick := time.NewTicker(updateInterval)
de
defer tick.Stop()
dumplingServiceSafePointID := fmt.Sprintf("%s_%d", drainerServiceSafePointPrefix, time.Now().UnixNano())
log.Info("generate drainer gc safePoint id", zap.String("id", dumplingServiceSafePointID))

Expand Down

0 comments on commit 19e727c

Please sign in to comment.