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 2ec8b67852ef..4341c413c9d5 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 @@ -1452,7 +1452,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 @@ -1460,7 +1462,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 @@ -1468,7 +1472,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)