tikv run gc synchronously (#3432)

Signed-off-by: xixi <hexilee@juicedata.io>
juicedata · Apr 4, 2023 · aacda0b · aacda0b
1 parent 3bdef3d
commit aacda0b
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/pkg/meta/tkv_tikv.go b/pkg/meta/tkv_tikv.go
@@ -310,12 +310,10 @@ func (c *tikvClient) gc() {
 	if c.gcInterval == 0 {
 		return
 	}
-	go func() {
-		safePoint, err := c.client.GC(context.Background(), oracle.GoTimeToTS(time.Now().Add(-c.gcInterval)))
-		if err == nil {
-			logger.Debugf("TiKV GC returns new safe point: %d (%s)", safePoint, oracle.GetTimeFromTS(safePoint))
-		} else {
-			logger.Warnf("TiKV GC: %s", err)
-		}
-	}()
+	safePoint, err := c.client.GC(context.Background(), oracle.GoTimeToTS(time.Now().Add(-c.gcInterval)))
+	if err == nil {
+		logger.Debugf("TiKV GC returns new safe point: %d (%s)", safePoint, oracle.GetTimeFromTS(safePoint))
+	} else {
+		logger.Warnf("TiKV GC: %s", err)
+	}
 }