We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4d43264 commit 799e684Copy full SHA for 799e684
src/common/storage/src/operator.rs
@@ -249,6 +249,14 @@ fn init_s3_operator(cfg: &StorageS3Config) -> Result<impl Builder> {
249
// Enable trust dns
250
builder = builder.trust_dns(true);
251
252
+ // Pool max idle per host controls connection pool size.
253
+ // Default to no limit, set to `0` for disable it.
254
+ let pool_max_idle_per_host = env::var("_DATABEND_INTERNAL_POOL_MAX_IDLE_PER_HOST")
255
+ .ok()
256
+ .and_then(|v| v.parse::<usize>().ok())
257
+ .unwrap_or(usize::MAX);
258
+ builder = builder.pool_max_idle_per_host(pool_max_idle_per_host);
259
+
260
// Connect timeout default to 30s.
261
let connect_timeout = env::var("_DATABEND_INTERNAL_CONNECT_TIMEOUT")
262
.ok()
0 commit comments