From e513c9132cb8560078806b02c4dc221635192a0c Mon Sep 17 00:00:00 2001 From: Dmitry Kropachev Date: Wed, 10 May 2023 04:26:21 -0400 Subject: [PATCH] fix(inflight): reduce shrinking limit inflights are initialized per partition, so limit of 1000000 makes no sense --- inflight/inflight.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/inflight/inflight.go b/inflight/inflight.go index a37390b7..88ce1116 100644 --- a/inflight/inflight.go +++ b/inflight/inflight.go @@ -21,7 +21,7 @@ import ( // We track inflights in the map, maps in golang are not shrinking // Therefore we track how many inflights were deleted and when it reaches the limit // we forcefully recreate the map to shrink it -const shrinkInflightsLimit = 1000000 +const shrinkInflightsLimit = 1000 type InFlight interface { AddIfNotPresent(uint64) bool