From 94d12f1485143c4d82a7ba088fdbbccd6fbfa727 Mon Sep 17 00:00:00 2001 From: gunli <24350715@qq.com> Date: Fri, 17 Jan 2025 18:03:23 +0800 Subject: [PATCH] [INLONG-11663][SDK] Increase the conn pool size for Golang SDK (#11677) --- .../dataproxy-sdk-golang/dataproxy/client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go index 3e1238ce94..a4aec4c36b 100755 --- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go +++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go @@ -166,7 +166,7 @@ func (c *client) initConns() error { // minimum connection number per endpoint is 1 connsPerEndpoint := int(math.Ceil(float64(c.options.WorkerNum) * 1.2 / float64(epLen))) - pool, err := connpool.NewConnPool(endpoints, connsPerEndpoint, 512, c, c.log, c.options.MaxConnLifetime) + pool, err := connpool.NewConnPool(endpoints, connsPerEndpoint, 2048, c, c.log, c.options.MaxConnLifetime) if err != nil { return err }