|
@@ -543,8 +543,7 @@ public class S3AFileSystem extends FileSystem implements StreamCapabilities,
|
|
DEFAULT_MULTIPART_UPLOAD_ENABLED);
|
|
DEFAULT_MULTIPART_UPLOAD_ENABLED);
|
|
this.prefetchEnabled = conf.getBoolean(PREFETCH_ENABLED_KEY, PREFETCH_ENABLED_DEFAULT);
|
|
this.prefetchEnabled = conf.getBoolean(PREFETCH_ENABLED_KEY, PREFETCH_ENABLED_DEFAULT);
|
|
long prefetchBlockSizeLong =
|
|
long prefetchBlockSizeLong =
|
|
- longBytesOption(conf, PREFETCH_BLOCK_SIZE_KEY, PREFETCH_BLOCK_DEFAULT_SIZE,
|
|
|
|
- PREFETCH_BLOCK_DEFAULT_SIZE);
|
|
|
|
|
|
+ longBytesOption(conf, PREFETCH_BLOCK_SIZE_KEY, PREFETCH_BLOCK_DEFAULT_SIZE, 1);
|
|
if (prefetchBlockSizeLong > (long) Integer.MAX_VALUE) {
|
|
if (prefetchBlockSizeLong > (long) Integer.MAX_VALUE) {
|
|
throw new IOException("S3A prefetch block size exceeds int limit");
|
|
throw new IOException("S3A prefetch block size exceeds int limit");
|
|
}
|
|
}
|