Skip to content

Commit 65dd398

Browse files
bigsheeperbigsheeper
authored
fix: Fix ants.Pool goroutine leak (#41892)
1. Release the pool after it is no longer in use. 2. Upgrade ants.Pool to fix the goroutine leak issue (see [PR #287](panjf2000/ants#287)). issue: #41838 --------- Signed-off-by: bigsheeper <[email protected]>
1 parent b932e03 commit 65dd398

File tree

19 files changed

+63
-36
lines changed

19 files changed

+63
-36
lines changed

‎client/go.mod

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,9 @@ require (
1010
github.com/milvus-io/milvus/pkg/v2 v2.0.0-20250319085209-5a6b4e56d59e
1111
github.com/quasilyte/go-ruleguard/dsl v0.3.22
1212
github.com/samber/lo v1.27.0
13-
github.com/stretchr/testify v1.9.0
13+
github.com/stretchr/testify v1.10.0
1414
github.com/tidwall/gjson v1.17.1
15-
go.opentelemetry.io/otel v1.28.0
1615
go.uber.org/atomic v1.11.0
17-
golang.org/x/exp v0.0.0-20240506185415-9bf2ced13842
1816
google.golang.org/grpc v1.65.0
1917
google.golang.org/protobuf v1.34.2
2018
)
@@ -55,7 +53,7 @@ require (
5553
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
5654
github.com/modern-go/reflect2 v1.0.2 // indirect
5755
github.com/opencontainers/runtime-spec v1.0.2 // indirect
58-
github.com/panjf2000/ants/v2 v2.7.2 // indirect
56+
github.com/panjf2000/ants/v2 v2.11.3 // indirect
5957
github.com/pkg/errors v0.9.1 // indirect
6058
github.com/pmezard/go-difflib v1.0.0 // indirect
6159
github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c // indirect
@@ -89,6 +87,7 @@ require (
8987
go.etcd.io/etcd/raft/v3 v3.5.5 // indirect
9088
go.etcd.io/etcd/server/v3 v3.5.5 // indirect
9189
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.49.0 // indirect
90+
go.opentelemetry.io/otel v1.28.0 // indirect
9291
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.20.0 // indirect
9392
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.20.0 // indirect
9493
go.opentelemetry.io/otel/metric v1.28.0 // indirect
@@ -99,6 +98,7 @@ require (
9998
go.uber.org/multierr v1.11.0 // indirect
10099
go.uber.org/zap v1.27.0 // indirect
101100
golang.org/x/crypto v0.36.0 // indirect
101+
golang.org/x/exp v0.0.0-20240506185415-9bf2ced13842 // indirect
102102
golang.org/x/net v0.38.0 // indirect
103103
golang.org/x/sync v0.12.0 // indirect
104104
golang.org/x/sys v0.31.0 // indirect

‎client/go.sum

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -351,8 +351,8 @@ github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7J
351351
github.com/opencontainers/runtime-spec v1.0.2 h1:UfAcuLBJB9Coz72x1hgl8O5RVzTdNiaglX6v2DM6FI0=
352352
github.com/opencontainers/runtime-spec v1.0.2/go.mod h1:jwyrGlmzljRJv/Fgzds9SsS/C5hL+LL3ko9hs6T5lQ0=
353353
github.com/opentracing/opentracing-go v1.1.0/go.mod h1:UkNAQd3GIcIGf0SeVgPpRdFStlNbqXla1AfSYxPUl2o=
354-
github.com/panjf2000/ants/v2 v2.7.2 h1:2NUt9BaZFO5kQzrieOmK/wdb/tQ/K+QHaxN8sOgD63U=
355-
github.com/panjf2000/ants/v2 v2.7.2/go.mod h1:KIBmYG9QQX5U2qzFP/yQJaq/nSb6rahS9iEHkrCMgM8=
354+
github.com/panjf2000/ants/v2 v2.11.3 h1:AfI0ngBoXJmYOpDh9m516vjqoUu2sLrIVgppI9TZVpg=
355+
github.com/panjf2000/ants/v2 v2.11.3/go.mod h1:8u92CYMUc6gyvTIw8Ru7Mt7+/ESnJahz5EVtqfrilek=
356356
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
357357
github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic=
358358
github.com/pingcap/errors v0.11.4/go.mod h1:Oi8TUi2kEtXXLMJk9l1cGmz20kV3TaQ0usTwv5KuLY8=
@@ -449,7 +449,6 @@ github.com/spf13/viper v1.7.0/go.mod h1:8WkrPz2fc9jxqZNCJI/76HCieCp4Q8HaLFoCha5q
449449
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
450450
github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
451451
github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
452-
github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
453452
github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
454453
github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
455454
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
@@ -459,9 +458,8 @@ github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5
459458
github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
460459
github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
461460
github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
462-
github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
463-
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
464-
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
461+
github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
462+
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
465463
github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
466464
github.com/thoas/go-funk v0.9.1 h1:O549iLZqPpTUQ10ykd26sZhzD+rmR5pWhuElrhbC20M=
467465
github.com/thoas/go-funk v0.9.1/go.mod h1:+IWnUfUmFO1+WVYQWQtIJHeRRdaIyyYglZN7xzUPe4Q=
@@ -649,7 +647,6 @@ golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJ
649647
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
650648
golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
651649
golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
652-
golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
653650
golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw=
654651
golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
655652
golang.org/x/sys v0.0.0-20180823144017-11551d06cbcc/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=

‎go.mod

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ require (
2323
github.com/mgutz/ansi v0.0.0-20200706080929-d51e80ef957d
2424
github.com/milvus-io/milvus-proto/go-api/v2 v2.5.0-beta.0.20250514091016-4080770055ad
2525
github.com/minio/minio-go/v7 v7.0.73
26+
github.com/panjf2000/ants/v2 v2.11.3 // indirect
2627
github.com/pingcap/log v1.1.1-0.20221015072633-39906604fb81
2728
github.com/prometheus/client_golang v1.14.0
2829
github.com/prometheus/client_model v0.3.0
@@ -33,7 +34,7 @@ require (
3334
github.com/soheilhy/cmux v0.1.5
3435
github.com/spf13/cast v1.3.1
3536
github.com/spf13/viper v1.8.1
36-
github.com/stretchr/testify v1.9.0
37+
github.com/stretchr/testify v1.10.0
3738
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.865 // indirect
3839
github.com/tikv/client-go/v2 v2.0.4
3940
go.etcd.io/etcd/api/v3 v3.5.5
@@ -196,7 +197,6 @@ require (
196197
github.com/mtibben/percent v0.2.1 // indirect
197198
github.com/opencontainers/runtime-spec v1.0.2 // indirect
198199
github.com/opentracing/opentracing-go v1.2.0 // indirect
199-
github.com/panjf2000/ants/v2 v2.7.2 // indirect
200200
github.com/pelletier/go-toml v1.9.3 // indirect
201201
github.com/pelletier/go-toml/v2 v2.0.8 // indirect
202202
github.com/pierrec/lz4 v2.5.2+incompatible // indirect

‎go.sum

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -799,8 +799,8 @@ github.com/opencontainers/runtime-spec v1.0.2/go.mod h1:jwyrGlmzljRJv/Fgzds9SsS/
799799
github.com/opentracing/opentracing-go v1.1.0/go.mod h1:UkNAQd3GIcIGf0SeVgPpRdFStlNbqXla1AfSYxPUl2o=
800800
github.com/opentracing/opentracing-go v1.2.0 h1:uEJPy/1a5RIPAJ0Ov+OIO8OxWu77jEv+1B0VhjKrZUs=
801801
github.com/opentracing/opentracing-go v1.2.0/go.mod h1:GxEUsuufX4nBwe+T+Wl9TAgYrxe9dPLANfrWvHYVTgc=
802-
github.com/panjf2000/ants/v2 v2.7.2 h1:2NUt9BaZFO5kQzrieOmK/wdb/tQ/K+QHaxN8sOgD63U=
803-
github.com/panjf2000/ants/v2 v2.7.2/go.mod h1:KIBmYG9QQX5U2qzFP/yQJaq/nSb6rahS9iEHkrCMgM8=
802+
github.com/panjf2000/ants/v2 v2.11.3 h1:AfI0ngBoXJmYOpDh9m516vjqoUu2sLrIVgppI9TZVpg=
803+
github.com/panjf2000/ants/v2 v2.11.3/go.mod h1:8u92CYMUc6gyvTIw8Ru7Mt7+/ESnJahz5EVtqfrilek=
804804
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
805805
github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic=
806806
github.com/pelletier/go-toml v1.9.3 h1:zeC5b1GviRUyKYd6OJPvBU/mcVDVoL1OhT17FCt5dSQ=
@@ -985,8 +985,8 @@ github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o
985985
github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
986986
github.com/stretchr/testify v1.8.3/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
987987
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
988-
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
989-
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
988+
github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
989+
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
990990
github.com/subosito/gotenv v1.2.0 h1:Slr1R9HxAlEKefgq5jn9U+DnETlIUa6HfgEzj0g5d7s=
991991
github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
992992
github.com/tebeka/strftime v0.1.3/go.mod h1:7wJm3dZlpr4l/oVK0t1HYIc4rMzQ2XJlOMIUJUJH6XQ=
@@ -1313,7 +1313,6 @@ golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208/go.mod h1:RxMgew5VJxzue5/jJ
13131313
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
13141314
golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
13151315
golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
1316-
golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
13171316
golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw=
13181317
golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
13191318
golang.org/x/sys v0.0.0-20180823144017-11551d06cbcc/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=

‎internal/datacoord/garbage_collector.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -235,6 +235,9 @@ func (gc *garbageCollector) close() {
235235
gc.stopOnce.Do(func() {
236236
gc.cancel()
237237
gc.wg.Wait()
238+
if gc.option.removeObjectPool != nil {
239+
gc.option.removeObjectPool.Release()
240+
}
238241
})
239242
}
240243

‎internal/datacoord/meta.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -227,6 +227,7 @@ func (m *meta) reloadFromKV(ctx context.Context, broker broker.Broker) error {
227227
}
228228

229229
pool := conc.NewPool[any](paramtable.Get().MetaStoreCfg.ReadConcurrency.GetAsInt())
230+
defer pool.Release()
230231
futures := make([]*conc.Future[any], 0, len(collectionIDs))
231232
collectionSegments := make([][]*datapb.SegmentInfo, len(collectionIDs))
232233
for i, collectionID := range collectionIDs {

‎internal/datacoord/services.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1770,6 +1770,7 @@ func (s *Server) ImportV2(ctx context.Context, in *internalpb.ImportRequestInter
17701770
if isBackup {
17711771
files = make([]*internalpb.ImportFile, 0)
17721772
pool := conc.NewPool[struct{}](hardware.GetCPUNum() * 2)
1773+
defer pool.Release()
17731774
futures := make([]*conc.Future[struct{}], 0, len(in.GetFiles()))
17741775
mu := &sync.Mutex{}
17751776
for _, importFile := range in.GetFiles() {

‎internal/datanode/compactor/clustering_compactor.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -777,6 +777,12 @@ func (t *clusteringCompactionTask) uploadPartitionStats(ctx context.Context, col
777777

778778
// cleanUp try best to clean all temp datas
779779
func (t *clusteringCompactionTask) cleanUp(ctx context.Context) {
780+
if t.mappingPool != nil {
781+
t.mappingPool.Release()
782+
}
783+
if t.flushPool != nil {
784+
t.flushPool.Release()
785+
}
780786
}
781787

782788
func (t *clusteringCompactionTask) scalarAnalyze(ctx context.Context) (map[interface{}]int64, error) {

‎internal/distributed/streaming/wal.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -181,6 +181,12 @@ func (w *walAccesserImpl) Close() {
181181
w.handlerClient.Close()
182182
}
183183
w.streamingCoordClient.Close()
184+
if w.appendExecutionPool != nil {
185+
w.appendExecutionPool.Release()
186+
}
187+
if w.dispatchExecutionPool != nil {
188+
w.dispatchExecutionPool.Release()
189+
}
184190
}
185191

186192
// newErrScanner creates a scanner that returns an error.

‎internal/proxy/task_scheduler.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -531,6 +531,7 @@ func (sched *taskScheduler) definitionLoop() {
531531
defer sched.wg.Done()
532532

533533
pool := conc.NewPool[struct{}](paramtable.Get().ProxyCfg.DDLConcurrency.GetAsInt(), conc.WithExpiryDuration(time.Minute))
534+
defer pool.Release()
534535
for {
535536
select {
536537
case <-sched.ctx.Done():
@@ -553,6 +554,7 @@ func (sched *taskScheduler) controlLoop() {
553554
defer sched.wg.Done()
554555

555556
pool := conc.NewPool[struct{}](paramtable.Get().ProxyCfg.DCLConcurrency.GetAsInt(), conc.WithExpiryDuration(time.Minute))
557+
defer pool.Release()
556558
for {
557559
select {
558560
case <-sched.ctx.Done():
@@ -573,6 +575,7 @@ func (sched *taskScheduler) controlLoop() {
573575
func (sched *taskScheduler) manipulationLoop() {
574576
defer sched.wg.Done()
575577
pool := conc.NewPool[struct{}](paramtable.Get().ProxyCfg.MaxTaskNum.GetAsInt())
578+
defer pool.Release()
576579
for {
577580
select {
578581
case <-sched.ctx.Done():
@@ -596,6 +599,8 @@ func (sched *taskScheduler) queryLoop() {
596599
poolSize := paramtable.Get().ProxyCfg.MaxTaskNum.GetAsInt()
597600
pool := conc.NewPool[struct{}](poolSize, conc.WithExpiryDuration(time.Minute))
598601
subTaskPool := conc.NewPool[struct{}](poolSize, conc.WithExpiryDuration(time.Minute))
602+
defer pool.Release()
603+
defer subTaskPool.Release()
599604

600605
for {
601606
select {

‎internal/querycoordv2/observers/task_dispatcher.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,9 @@ func (d *taskDispatcher[K]) Stop() {
6767
d.cancel()
6868
}
6969
d.wg.Wait()
70+
if d.pool != nil {
71+
d.pool.Release()
72+
}
7073
})
7174
}
7275

‎internal/streamingnode/server/wal/adaptor/wal_adaptor.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -282,6 +282,10 @@ func (w *walAdaptorImpl) Close() {
282282
// close all metrics.
283283
w.scanMetrics.Close()
284284
w.writeMetrics.Close()
285+
286+
if w.appendExecutionPool != nil {
287+
w.appendExecutionPool.Release()
288+
}
285289
}
286290

287291
type interceptorBuildResult struct {

‎internal/util/searchutil/scheduler/concurrent_safe_scheduler.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,12 @@ func (s *scheduler) Stop() {
103103
close(s.receiveChan)
104104
// wait workers quit
105105
s.wg.Wait()
106+
if s.pool != nil {
107+
s.pool.Release()
108+
}
109+
if s.gpuPool != nil {
110+
s.gpuPool.Release()
111+
}
106112
}
107113

108114
// schedule the owned task asynchronously and continuously.

‎pkg/go.mod

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ require (
2222
github.com/klauspost/compress v1.17.9
2323
github.com/milvus-io/milvus-proto/go-api/v2 v2.5.0-beta.0.20250514091016-4080770055ad
2424
github.com/minio/minio-go/v7 v7.0.73
25-
github.com/panjf2000/ants/v2 v2.7.2
25+
github.com/panjf2000/ants/v2 v2.11.3
2626
github.com/prometheus/client_golang v1.14.0
2727
github.com/quasilyte/go-ruleguard/dsl v0.3.22
2828
github.com/remeh/sizedwaitgroup v1.0.0
@@ -32,7 +32,7 @@ require (
3232
github.com/spaolacci/murmur3 v1.1.0
3333
github.com/spf13/cast v1.3.1
3434
github.com/streamnative/pulsarctl v0.5.0
35-
github.com/stretchr/testify v1.9.0
35+
github.com/stretchr/testify v1.10.0
3636
github.com/tecbot/gorocksdb v0.0.0-20191217155057-f0fad39f321c
3737
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.865
3838
github.com/tidwall/gjson v1.17.0

‎pkg/go.sum

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -610,8 +610,8 @@ github.com/opencontainers/runtime-spec v1.0.2/go.mod h1:jwyrGlmzljRJv/Fgzds9SsS/
610610
github.com/opentracing/opentracing-go v1.1.0/go.mod h1:UkNAQd3GIcIGf0SeVgPpRdFStlNbqXla1AfSYxPUl2o=
611611
github.com/opentracing/opentracing-go v1.2.0 h1:uEJPy/1a5RIPAJ0Ov+OIO8OxWu77jEv+1B0VhjKrZUs=
612612
github.com/opentracing/opentracing-go v1.2.0/go.mod h1:GxEUsuufX4nBwe+T+Wl9TAgYrxe9dPLANfrWvHYVTgc=
613-
github.com/panjf2000/ants/v2 v2.7.2 h1:2NUt9BaZFO5kQzrieOmK/wdb/tQ/K+QHaxN8sOgD63U=
614-
github.com/panjf2000/ants/v2 v2.7.2/go.mod h1:KIBmYG9QQX5U2qzFP/yQJaq/nSb6rahS9iEHkrCMgM8=
613+
github.com/panjf2000/ants/v2 v2.11.3 h1:AfI0ngBoXJmYOpDh9m516vjqoUu2sLrIVgppI9TZVpg=
614+
github.com/panjf2000/ants/v2 v2.11.3/go.mod h1:8u92CYMUc6gyvTIw8Ru7Mt7+/ESnJahz5EVtqfrilek=
615615
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
616616
github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic=
617617
github.com/pierrec/lz4 v2.5.2+incompatible h1:WCjObylUIOlKy/+7Abdn34TLIkXiA4UWUMhxq9m9ZXI=
@@ -761,8 +761,8 @@ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/
761761
github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
762762
github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
763763
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
764-
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
765-
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
764+
github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
765+
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
766766
github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
767767
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.865 h1:LcUqBlKC4j15LhT303yQDX/XxyHG4haEQqbHgZZA4SY=
768768
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.865/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
@@ -1039,7 +1039,6 @@ golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208/go.mod h1:RxMgew5VJxzue5/jJ
10391039
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
10401040
golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
10411041
golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
1042-
golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
10431042
golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw=
10441043
golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
10451044
golang.org/x/sys v0.0.0-20180823144017-11551d06cbcc/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=

‎pkg/util/conc/options.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ package conc
1919
import (
2020
"time"
2121

22-
"github.com/panjf2000/ants/v2"
22+
ants "github.com/panjf2000/ants/v2"
2323
"go.uber.org/zap"
2424

2525
"github.com/milvus-io/milvus/pkg/v2/log"

‎pkg/util/conc/pool.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import (
2222
"sync"
2323
"time"
2424

25-
"github.com/panjf2000/ants/v2"
25+
ants "github.com/panjf2000/ants/v2"
2626

2727
"github.com/milvus-io/milvus/pkg/v2/util/generic"
2828
"github.com/milvus-io/milvus/pkg/v2/util/hardware"

‎tests/go_client/go.mod

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ require (
77
github.com/milvus-io/milvus/pkg/v2 v2.0.0-20250319085209-5a6b4e56d59e
88
github.com/quasilyte/go-ruleguard/dsl v0.3.22
99
github.com/samber/lo v1.27.0
10-
github.com/stretchr/testify v1.9.0
10+
github.com/stretchr/testify v1.10.0
1111
github.com/x448/float16 v0.8.4
1212
go.uber.org/zap v1.27.0
1313
google.golang.org/grpc v1.65.0
@@ -55,7 +55,7 @@ require (
5555
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
5656
github.com/modern-go/reflect2 v1.0.2 // indirect
5757
github.com/opencontainers/runtime-spec v1.0.2 // indirect
58-
github.com/panjf2000/ants/v2 v2.7.2 // indirect
58+
github.com/panjf2000/ants/v2 v2.11.3 // indirect
5959
github.com/pkg/errors v0.9.1 // indirect
6060
github.com/pmezard/go-difflib v1.0.0 // indirect
6161
github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c // indirect

0 commit comments

Comments
 (0)