diff --git a/presto-iceberg/pom.xml b/presto-iceberg/pom.xml index 8b9bbf6d3f4ea..5f0f27b3566ad 100644 --- a/presto-iceberg/pom.xml +++ b/presto-iceberg/pom.xml @@ -12,7 +12,7 @@ ${project.parent.basedir} - 0.14.1 + 1.0.0 0.43.0 diff --git a/presto-iceberg/src/main/java/com/facebook/presto/iceberg/ManifestsTable.java b/presto-iceberg/src/main/java/com/facebook/presto/iceberg/ManifestsTable.java index 295b835607ee2..6c176541c8cef 100644 --- a/presto-iceberg/src/main/java/com/facebook/presto/iceberg/ManifestsTable.java +++ b/presto-iceberg/src/main/java/com/facebook/presto/iceberg/ManifestsTable.java @@ -111,7 +111,7 @@ private static List buildPages(ConnectorTableMetadata tableMetadata, Table Map partitionSpecsById = icebergTable.specs(); - snapshot.allManifests().forEach(file -> { + snapshot.allManifests(icebergTable.io()).forEach(file -> { pagesBuilder.beginRow(); pagesBuilder.appendVarchar(file.path()); pagesBuilder.appendBigint(file.length()); diff --git a/presto-iceberg/src/main/java/com/facebook/presto/iceberg/RollbackToSnapshotProcedure.java b/presto-iceberg/src/main/java/com/facebook/presto/iceberg/RollbackToSnapshotProcedure.java index acf3013afc309..8a4028f0eadbc 100644 --- a/presto-iceberg/src/main/java/com/facebook/presto/iceberg/RollbackToSnapshotProcedure.java +++ b/presto-iceberg/src/main/java/com/facebook/presto/iceberg/RollbackToSnapshotProcedure.java @@ -91,6 +91,6 @@ public void rollbackToSnapshot(ConnectorSession clientSession, String schema, St ExtendedHiveMetastore metastore = ((IcebergHiveMetadata) metadata).getMetastore(); icebergTable = getHiveIcebergTable(metastore, hdfsEnvironment, clientSession, schemaTableName); } - icebergTable.rollback().toSnapshotId(snapshotId).commit(); + icebergTable.manageSnapshots().rollbackTo(snapshotId).commit(); } }