From 463e7bd46dfe062064c89e053ee5bbe180c14bd1 Mon Sep 17 00:00:00 2001 From: Chunzhu Li Date: Mon, 29 May 2023 14:16:32 +0800 Subject: [PATCH] address comment --- drainer/safepoint.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/drainer/safepoint.go b/drainer/safepoint.go index 645d09bf4..be7f1b682 100644 --- a/drainer/safepoint.go +++ b/drainer/safepoint.go @@ -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))