From cab8a416c4c2ad8a0db4f4611922759c8f864548 Mon Sep 17 00:00:00 2001 From: Ahmar Suhail Date: Fri, 7 Mar 2025 15:06:33 +0000 Subject: [PATCH] fix typo --- .../java/org/apache/hadoop/fs/s3a/DefaultS3ClientFactory.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/DefaultS3ClientFactory.java b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/DefaultS3ClientFactory.java index db1fdf8708452..c14a360965849 100644 --- a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/DefaultS3ClientFactory.java +++ b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/DefaultS3ClientFactory.java @@ -173,11 +173,11 @@ private S3AsyncClient createS3CrtAsyncClient(URI uri, S3ClientCreationParameters AWSRegionEndpointInformation regionEndpointInformation = AWSRegionEndpointResolver.getEndpointRegionResolution(parameters, conf); - if (regionEndpointInformation.getRegion() == null) { + if (regionEndpointInformation.getRegion() != null) { s3CrtAsyncClientBuilder.region(regionEndpointInformation.getRegion()); } - if (regionEndpointInformation.getEndpoint() == null) { + if (regionEndpointInformation.getEndpoint() != null) { s3CrtAsyncClientBuilder.endpointOverride(regionEndpointInformation.getEndpoint()); }