fix typo

apache · Mar 7, 2025 · cab8a41 · cab8a41
1 parent f72e64a
commit cab8a41
Showing 1 changed file with 2 additions and 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
@@ -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());
     }