From 941d20e08590fd3be6b9c546265016b744843007 Mon Sep 17 00:00:00 2001
From: can <can@canx.me>
Date: Mon, 20 Apr 2020 11:11:49 +0800
Subject: [PATCH] Remove error output of rateLimiter

Tons of useless output generated
---
 go.mod      | 2 +-
 meta/qos.go | 3 ---
 2 files changed, 1 insertion(+), 4 deletions(-)

diff --git a/go.mod b/go.mod
index 8fa8974b3..1b8725626 100644
--- a/go.mod
+++ b/go.mod
@@ -33,7 +33,7 @@ require (
 	github.com/confluentinc/confluent-kafka-go v1.0.0 //ct
 	github.com/dgrijalva/jwt-go v3.2.0+incompatible
 	github.com/dustin/go-humanize v1.0.0
-	github.com/go-redis/redis/v7 v7.0.0-beta.4
+	github.com/go-redis/redis/v7 v7.2.0
 	github.com/go-redis/redis_rate/v8 v8.0.0
 	github.com/go-sql-driver/mysql v1.4.1
 	github.com/golang/snappy v0.0.1
diff --git a/meta/qos.go b/meta/qos.go
index ef7ce89af..538f14c63 100644
--- a/meta/qos.go
+++ b/meta/qos.go
@@ -53,7 +53,6 @@ func (m *QosMeta) AllowReadQuery(bucketName string) (allow bool) {
 	// the key actually used in redis would have a prefix "rate:"
 	result, err := m.rateLimiter.Allow(key, redis_rate.PerSecond(qps))
 	if err != nil {
-		helper.Logger.Error("AllowReadQuery:", err)
 		return true
 	}
 	return result.Allowed
@@ -69,7 +68,6 @@ func (m *QosMeta) AllowWriteQuery(bucketName string) (allow bool) {
 	// the key actually used in redis would have a prefix "rate:"
 	result, err := m.rateLimiter.Allow(key, redis_rate.PerSecond(qps))
 	if err != nil {
-		helper.Logger.Error("AllowWriteQuery:", err)
 		return true
 	}
 	return result.Allowed
@@ -154,7 +152,6 @@ func (t *throttler) maybeWaitTokenN(n int) {
 		result, err := t.rateLimiter.AllowN(key,
 			redis_rate.PerSecond(t.kbpsLimit*1024), n)
 		if err != nil {
-			helper.Logger.Error("ThrottleReader:", err)
 			return
 		}
 		if result.Allowed {