Skip to content

Commit 31250fd

Browse files
committed
remove copied classes in favor the originals
1 parent fa4409f commit 31250fd

File tree

14 files changed

+5
-4260
lines changed

14 files changed

+5
-4260
lines changed

iceberg/iceberg-handler/src/main/java/org/apache/iceberg/data/PartitionStatsHandler.java

Lines changed: 0 additions & 259 deletions
This file was deleted.

iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergStorageHandler.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -549,7 +549,11 @@ public Map<String, String> computeBasicStatistics(Partish partish) {
549549
if (snapshot != null && table.spec().isPartitioned()) {
550550
PartitionStatisticsFile statsFile = IcebergTableUtil.getPartitionStatsFile(table, snapshot.snapshotId());
551551
if (statsFile == null) {
552-
statsFile = PartitionStatsHandler.computeAndWriteStatsFile(table);
552+
try {
553+
statsFile = PartitionStatsHandler.computeAndWriteStatsFile(table);
554+
} catch (IOException e) {
555+
throw new UncheckedIOException(e);
556+
}
553557

554558
table.updatePartitionStatistics()
555559
.setPartitionStatistics(statsFile)

0 commit comments

Comments
 (0)