milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: reset the quota value when init the limiter (#33111) 

issue: #33107
/kind improvement

Signed-off-by: SimFG <bang.fu@zilliz.com>
pull/33156/head
SimFG 2024-05-20 10:35:38 +08:00 committed by GitHub
parent a7f6193bfc
commit ec98de3ad4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/proxy/simple_rate_limiter.go
View File

@ -202,7 +202,7 @@ func initLimiter(rln *rlinternal.RateLimiterNode, rateLimiterConfigs map[interna
for rt, p := range rateLimiterConfigs {
limit := ratelimitutil.Limit(p.GetAsFloat())
burst := p.GetAsFloat() // use rate as burst, because SimpleLimiter is with punishment mechanism, burst is insignificant.
rln.GetLimiters().GetOrInsert(rt, ratelimitutil.NewLimiter(limit, burst))
rln.GetLimiters().Insert(rt, ratelimitutil.NewLimiter(limit, burst))
log.RatedDebug(30, "RateLimiter register for rateType",
zap.String("rateType", internalpb.RateType_name[(int32(rt))]),
zap.String("rateLimit", ratelimitutil.Limit(p.GetAsFloat()).String()),