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 ab1e4adedd5a..c6a15a8e6db6 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 @@ -1430,7 +1430,9 @@ public void addColumn(ConnectorSession session, ConnectorTableHandle tableHandle throw new TrinoException(NOT_SUPPORTED, "This connector does not support adding not null columns"); } Table icebergTable = catalog.loadTable(session, ((IcebergTableHandle) tableHandle).getSchemaTableName()); - icebergTable.updateSchema().addColumn(column.getName(), toIcebergType(column.getType()), column.getComment()).commit(); + icebergTable.updateSchema() + .addColumn(column.getName(), toIcebergType(column.getType()), column.getComment()) + .commit(); } @Override @@ -1438,7 +1440,9 @@ public void dropColumn(ConnectorSession session, ConnectorTableHandle tableHandl { IcebergColumnHandle handle = (IcebergColumnHandle) column; Table icebergTable = catalog.loadTable(session, ((IcebergTableHandle) tableHandle).getSchemaTableName()); - icebergTable.updateSchema().deleteColumn(handle.getName()).commit(); + icebergTable.updateSchema() + .deleteColumn(handle.getName()) + .commit(); } @Override @@ -1446,7 +1450,9 @@ public void renameColumn(ConnectorSession session, ConnectorTableHandle tableHan { IcebergColumnHandle columnHandle = (IcebergColumnHandle) source; Table icebergTable = catalog.loadTable(session, ((IcebergTableHandle) tableHandle).getSchemaTableName()); - icebergTable.updateSchema().renameColumn(columnHandle.getName(), target).commit(); + icebergTable.updateSchema() + .renameColumn(columnHandle.getName(), target) + .commit(); } private List getColumnMetadatas(Schema schema)