Skip to content

Commit 09e5f14

Browse files
authored
use v2 schema
1 parent 5df685e commit 09e5f14

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -553,8 +553,7 @@ private static Map<String, String> getPartishSummary(Partish partish, Table tabl
553553
PartitionStatisticsFile statsFile = IcebergTableUtil.getPartitionStatsFile(table, snapshot.snapshotId());
554554
if (statsFile != null) {
555555
Types.StructType partitionType = Partitioning.partitionType(table);
556-
Schema recordSchema = PartitionStatsHandler.schema(
557-
partitionType, ((BaseTable) table).operations().current().formatVersion());
556+
Schema recordSchema = PartitionStatsHandler.schema(partitionType);
558557

559558
try (CloseableIterable<PartitionStats> recordIterator = PartitionStatsHandler.readPartitionStatsFile(
560559
recordSchema, table.io().newInputFile(statsFile.path()))) {

0 commit comments

Comments
 (0)