diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java index cbc1d7252e46..12d0af474cb1 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java @@ -829,7 +829,7 @@ public Optional getInfo(ConnectorTableHandle tableHandle) @Override public void dropTable(ConnectorSession session, ConnectorTableHandle tableHandle) { - catalog.dropTable(session, ((IcebergTableHandle) tableHandle).getSchemaTableName(), true); + catalog.dropTable(session, ((IcebergTableHandle) tableHandle).getSchemaTableName()); } @Override diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoCatalog.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoCatalog.java index ca29c826e880..a66395459830 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoCatalog.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoCatalog.java @@ -68,7 +68,7 @@ Transaction newCreateTableTransaction( String location, Map properties); - void dropTable(ConnectorSession session, SchemaTableName schemaTableName, boolean purgeData); + void dropTable(ConnectorSession session, SchemaTableName schemaTableName); void renameTable(ConnectorSession session, SchemaTableName from, SchemaTableName to); diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java index 4b81bca2c479..35a07c275e79 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java @@ -295,7 +295,7 @@ public List listTables(ConnectorSession session, Optional