Skip to content

Commit 8b974bc

Browse files
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.
1 parent 0042544 commit 8b974bc

File tree

2 files changed

+1
-11
lines changed

2 files changed

+1
-11
lines changed

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1357,7 +1357,7 @@ public String getBucketLocation() throws IOException {
13571357
public String getBucketLocation(String bucketName) throws IOException {
13581358
final String region = trackDurationAndSpan(
13591359
STORE_EXISTS_PROBE, bucketName, null, () ->
1360-
once("getBucketLocation()", bucketName, () ->
1360+
invoker.retry("getBucketLocation()", bucketName, true, () ->
13611361
// If accessPoint then region is known from Arn
13621362
accessPoint != null
13631363
? accessPoint.getRegion()

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/auth/SignerFactory.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -81,16 +81,6 @@ public static void registerSigner(
8181
SIGNERS.put(signerType, signerClass);
8282
}
8383

84-
/**
85-
* Check if the signer has already been registered.
86-
* @param signerType signer to get
87-
* @throws IllegalArgumentException if the signer type is unknown.
88-
*/
89-
public static void verifySignerRegistered(String signerType) {
90-
checkArgument(isSignerRegistered(signerType),
91-
"unknown signer type: %s", signerType);
92-
}
93-
9484
/**
9585
* Check if the signer has already been registered.
9686
* @param signerType signer to get

0 commit comments

Comments
 (0)