This is an automated email from the ASF dual-hosted git repository. stevel pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/hadoop.git
commit 0e51a9b55e6f289a3b551cb057725c80802802f0 Author: Daniel Carl Jones <djone...@amazon.com> AuthorDate: Mon Oct 31 21:19:34 2022 +0000 HADOOP-18482. ITestS3APrefetchingInputStream to skip if CSV test file unavailable (#4983) Contributed by Danny Jones --- .../org/apache/hadoop/fs/s3a/ITestS3APrefetchingInputStream.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3APrefetchingInputStream.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3APrefetchingInputStream.java index 4fd50a3eb81..b1ab4afce47 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3APrefetchingInputStream.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3APrefetchingInputStream.java @@ -92,11 +92,12 @@ public class ITestS3APrefetchingInputStream extends AbstractS3ACostTest { private void openFS() throws Exception { Configuration conf = getConfiguration(); + String largeFileUri = S3ATestUtils.getCSVTestFile(conf); - largeFile = new Path(DEFAULT_CSVTEST_FILE); + largeFile = new Path(largeFileUri); blockSize = conf.getInt(PREFETCH_BLOCK_SIZE_KEY, PREFETCH_BLOCK_DEFAULT_SIZE); largeFileFS = new S3AFileSystem(); - largeFileFS.initialize(new URI(DEFAULT_CSVTEST_FILE), getConfiguration()); + largeFileFS.initialize(new URI(largeFileUri), getConfiguration()); FileStatus fileStatus = largeFileFS.getFileStatus(largeFile); largeFileSize = fileStatus.getLen(); numBlocks = calculateNumBlocks(largeFileSize, blockSize); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org