diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/RollbackToSnapshotProcedure.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/RollbackToSnapshotProcedure.java index d649362b7196..78c618bf3cef 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/RollbackToSnapshotProcedure.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/RollbackToSnapshotProcedure.java @@ -65,6 +65,6 @@ public void rollbackToSnapshot(ConnectorSession clientSession, String schema, St { SchemaTableName schemaTableName = new SchemaTableName(schema, table); Table icebergTable = catalogFactory.create().loadTable(clientSession, schemaTableName); - icebergTable.rollback().toSnapshotId(snapshotId).commit(); + icebergTable.manageSnapshots().setCurrentSnapshot(snapshotId).commit(); } }