From b2c596cdda7c129951074bc53b4b9ecfedbf080a Mon Sep 17 00:00:00 2001 From: Chris Nauroth Date: Tue, 21 Jun 2016 11:28:52 -0700 Subject: [PATCH] HADOOP-13287. TestS3ACredentials#testInstantiateFromURL fails if AWS secret key contains +. Contributed by Chris Nauroth. --- .../hadoop/fs/s3a/TestS3ACredentialsInURL.java | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/TestS3ACredentialsInURL.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/TestS3ACredentialsInURL.java index f1da72b4780..8cb7c0f0b1a 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/TestS3ACredentialsInURL.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/TestS3ACredentialsInURL.java @@ -33,7 +33,6 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.URI; -import java.net.URISyntaxException; import java.net.URLEncoder; import java.nio.file.AccessDeniedException; @@ -73,7 +72,11 @@ public class TestS3ACredentialsInURL extends Assert { accessKey, secretKey); if (secretKey.contains("/")) { assertTrue("test URI encodes the / symbol", secretsURI.toString(). - contains("%2F")); + contains("%252F")); + } + if (secretKey.contains("+")) { + assertTrue("test URI encodes the + symbol", secretsURI.toString(). + contains("%252B")); } assertFalse("Does not contain secrets", original.equals(secretsURI)); @@ -132,8 +135,7 @@ public class TestS3ACredentialsInURL extends Assert { private URI createUriWithEmbeddedSecrets(URI original, String accessKey, - String secretKey) throws URISyntaxException, - UnsupportedEncodingException { + String secretKey) throws UnsupportedEncodingException { String encodedSecretKey = URLEncoder.encode(secretKey, "UTF-8"); String formattedString = String.format("%s://%s:%s@%s/%s/", original.getScheme(), @@ -143,10 +145,10 @@ public class TestS3ACredentialsInURL extends Assert { original.getPath()); URI testURI; try { - testURI = new URI(formattedString); - } catch (URISyntaxException e) { + testURI = new Path(formattedString).toUri(); + } catch (IllegalArgumentException e) { // inner cause is stripped to keep any secrets out of stack traces - throw new URISyntaxException("", "Could not encode URI"); + throw new IllegalArgumentException("Could not encode Path"); } return testURI; }