This is an automated email from the ASF dual-hosted git repository.
stevel pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8b974bcc1f08 HADOOP-18889. Third party storage followup. (#6186)
8b974bcc1f08 is described below
commit 8b974bcc1f084ae77dccf99ebc243e7a571f2e11
Author: Steve Loughran <ste...@cloudera.com>
AuthorDate: Tue Oct 24 18:17:52 2023 +0100
HADOOP-18889. Third party storage followup. (#6186)
Followup to HADOOP-18889 third party store support;
Fix some minor review comments which came in after the merge.
---
.../src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java | 2 +-
.../main/java/org/apache/hadoop/fs/s3a/auth/SignerFactory.java | 10 ----------
2 files changed, 1 insertion(+), 11 deletions(-)
diff --git
a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java
b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java
index 8ab8d22cc6d8..d7149d7dead6 100644
---
a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java
+++
b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java
@@ -1357,7 +1357,7 @@ public class S3AFileSystem extends FileSystem implements
StreamCapabilities,
public String getBucketLocation(String bucketName) throws IOException {
final String region = trackDurationAndSpan(
STORE_EXISTS_PROBE, bucketName, null, () ->
- once("getBucketLocation()", bucketName, () ->
+ invoker.retry("getBucketLocation()", bucketName, true, () ->
// If accessPoint then region is known from Arn
accessPoint != null
? accessPoint.getRegion()
diff --git
a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/auth/SignerFactory.java
b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/auth/SignerFactory.java
index 5d34688cebe1..21c390c07940 100644
---
a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/auth/SignerFactory.java
+++
b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/auth/SignerFactory.java
@@ -81,16 +81,6 @@ public final class SignerFactory {
SIGNERS.put(signerType, signerClass);
}
- /**
- * Check if the signer has already been registered.
- * @param signerType signer to get
- * @throws IllegalArgumentException if the signer type is unknown.
- */
- public static void verifySignerRegistered(String signerType) {
- checkArgument(isSignerRegistered(signerType),
- "unknown signer type: %s", signerType);
- }
-
/**
* Check if the signer has already been registered.
* @param signerType signer to get
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
