Repository: hadoop Updated Branches: refs/heads/branch-2.8 834e2ddba -> 01e3b0dae
HADOOP-13801 regression: ITestS3AMiniYarnCluster failing. Contributed by Steve Loughran Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/01e3b0da Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/01e3b0da Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/01e3b0da Branch: refs/heads/branch-2.8 Commit: 01e3b0dae8c38478a1a9fec1bad948e9720f5b50 Parents: 834e2dd Author: Steve Loughran <[email protected]> Authored: Wed Nov 23 21:37:04 2016 +0000 Committer: Steve Loughran <[email protected]> Committed: Wed Nov 23 21:37:23 2016 +0000 ---------------------------------------------------------------------- .../hadoop/fs/s3a/yarn/ITestS3AMiniYarnCluster.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/01e3b0da/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/yarn/ITestS3AMiniYarnCluster.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/yarn/ITestS3AMiniYarnCluster.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/yarn/ITestS3AMiniYarnCluster.java index 8421dad..00bd866 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/yarn/ITestS3AMiniYarnCluster.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/yarn/ITestS3AMiniYarnCluster.java @@ -24,13 +24,14 @@ import java.util.Map; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.examples.WordCount; import org.apache.hadoop.fs.CreateFlag; +import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FSDataOutputStream; import org.apache.hadoop.fs.FileContext; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.fs.contract.ContractTestUtils; import org.apache.hadoop.fs.s3a.AbstractS3ATestBase; import org.apache.hadoop.fs.s3a.S3AFileSystem; import org.apache.hadoop.fs.s3a.S3ATestUtils; +import org.apache.hadoop.io.IOUtils; import org.apache.hadoop.io.IntWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Job; @@ -137,8 +138,12 @@ public class ITestS3AMiniYarnCluster extends AbstractS3ATestBase { * helper method. */ private String readStringFromFile(Path path) throws IOException { - return ContractTestUtils.readBytesToString(fs, path, - (int) fs.getFileStatus(path).getLen()); + try (FSDataInputStream in = fs.open(path)) { + long bytesLen = fs.getFileStatus(path).getLen(); + byte[] buffer = new byte[(int) bytesLen]; + IOUtils.readFully(in, buffer, 0, buffer.length); + return new String(buffer); + } } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
