(inlong) branch master updated: [INLONG-11663][SDK] Increase the conn pool size for Golang SDK (#11677)

[aloyszhang]

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 94d12f1485 [INLONG-11663][SDK] Increase the conn pool size for Golang 
SDK (#11677)
94d12f1485 is described below

commit 94d12f1485143c4d82a7ba088fdbbccd6fbfa727
Author: gunli <24350...@qq.com>
AuthorDate: Fri Jan 17 18:03:23 2025 +0800

    [INLONG-11663][SDK] Increase the conn pool size for Golang SDK (#11677)
---
 inlong-sdk/dataproxy-sdk-twins/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
        }