diff --git a/api/src/main/java/org/apache/iceberg/io/FileRange.java b/api/src/main/java/org/apache/iceberg/io/FileRange.java index f6d5d9b41cca..90d5754849ed 100644 --- a/api/src/main/java/org/apache/iceberg/io/FileRange.java +++ b/api/src/main/java/org/apache/iceberg/io/FileRange.java @@ -18,7 +18,6 @@ */ package org.apache.iceberg.io; -import java.io.EOFException; import java.nio.ByteBuffer; import java.util.concurrent.CompletableFuture; import org.apache.iceberg.relocated.com.google.common.base.Preconditions; @@ -28,8 +27,7 @@ public class FileRange { private final long offset; private final int length; - public FileRange(CompletableFuture byteBuffer, long offset, int length) - throws EOFException { + public FileRange(CompletableFuture byteBuffer, long offset, int length) { Preconditions.checkNotNull(byteBuffer, "byteBuffer can't be null"); Preconditions.checkArgument( length() >= 0, "Invalid length: %s in range (must be >= 0)", length); diff --git a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java index 7e0c7f5f3fb5..ecca4eb0d65a 100644 --- a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java +++ b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java @@ -18,7 +18,6 @@ */ package org.apache.iceberg.parquet; -import java.io.EOFException; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; @@ -187,18 +186,10 @@ private static List convertRanges(List ranges) { parquetFileRange -> { CompletableFuture future = new CompletableFuture<>(); parquetFileRange.setDataReadFuture(future); - try { - return new FileRange( - parquetFileRange.getDataReadFuture(), - parquetFileRange.getOffset(), - parquetFileRange.getLength()); - } catch (EOFException e) { - throw new RuntimeIOException( - e, - "Failed to create range file for offset: %s and length: %s", - parquetFileRange.getOffset(), - parquetFileRange.getLength()); - } + return new FileRange( + parquetFileRange.getDataReadFuture(), + parquetFileRange.getOffset(), + parquetFileRange.getLength()); }) .collect(Collectors.toList()); }