From 80daeb5a390efb5d14b93735e5987236b582ad61 Mon Sep 17 00:00:00 2001 From: Danny Mccormick Date: Mon, 23 Dec 2024 11:18:46 -0500 Subject: [PATCH] Make sure it gets set for now --- .../beam/sdk/io/aws2/common/ClientBuilderFactory.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java index 61916e091db..9a1772ce878 100644 --- a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java +++ b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java @@ -203,11 +203,11 @@ public , ClientT> BuilderT httpConfig.socketTimeout(), client::writeTimeout); // fallback for writeTimeout setOptional(httpConfig.writeTimeout(), client::writeTimeout); setOptional(httpConfig.maxConnections(), client::maxConcurrency); - - // TODO - gate this behind a flag. - client.tlsKeyManagersProvider(NoneTlsKeyManagersProvider.getInstance()); } + // TODO - gate this behind a flag. + client.tlsKeyManagersProvider(NoneTlsKeyManagersProvider.getInstance()); + // must use builder to make sure client is managed by the SDK ((SdkAsyncClientBuilder) builder).httpClientBuilder(client); }