diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go
index c79a9c5..9b00137 100644
--- a/internal/rdb/rdb.go
+++ b/internal/rdb/rdb.go
@@ -1451,6 +1451,7 @@ func (r *RDB) CancelationPubSub() (*redis.PubSub, error) {
 	pubsub := r.client.Subscribe(ctx, base.CancelChannel)
 	_, err := pubsub.Receive(ctx)
 	if err != nil {
+		_ = pubsub.Close()
 		return nil, errors.E(op, errors.Unknown, fmt.Sprintf("redis pubsub receive error: %v", err))
 	}
 	return pubsub, nil