From b5642c5638d24c2e8ae7f29d5dc6e3f91bb47cf5 Mon Sep 17 00:00:00 2001 From: ahmarsuhail Date: Fri, 5 Aug 2022 14:13:04 +0100 Subject: [PATCH] HADOOP-18366. ITestS3Select.testSelectSeekFullLandsat is timing out. (#4702) Reduces size of data read to 1 MB Contributed by Ahmar Suhail --- .../apache/hadoop/fs/s3a/select/ITestS3SelectLandsat.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/select/ITestS3SelectLandsat.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/select/ITestS3SelectLandsat.java index 8b0578df11..51da971fb7 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/select/ITestS3SelectLandsat.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/select/ITestS3SelectLandsat.java @@ -415,7 +415,7 @@ public class ITestS3SelectLandsat extends AbstractS3SelectTest { long increment = 64 * _1KB; // seek forward, comparing bytes - for(offset = 32 * _1KB; offset < actualLen; offset += increment) { + for(offset = 32 * _1KB; offset < _1MB; offset += increment) { seek(seekStream, offset); assertEquals("Seek position in " + seekStream, offset, seekStream.getPos()); @@ -423,11 +423,6 @@ public class ITestS3SelectLandsat extends AbstractS3SelectTest { assertEquals("byte at seek position", dataset[(int) seekStream.getPos()], seekStream.read()); } - for(; offset < len; offset += _1MB) { - seek(seekStream, offset); - assertEquals("Seek position in " + seekStream, - offset, seekStream.getPos()); - } // there's no knowledge of how much data is left, but with Gzip // involved there can be a lot. To keep the test duration down, // this test, unlike the simpler one, doesn't try to read past the