@VisibleForTesting
    protected synchronized void applySchemaChange(Table table, List<SchemaChange> changes) {
        LOGGER.info("Applying schema changes to table {}, changes {}", tableId, changes);
        Tasks.range(1)
            .retry(2)
            .run(notUsed -> applyChanges(table, changes));
        table.refresh();
    }
Apply schema changes to the table

@param changes list of schema changes
core/src/main/java/kafka/automq/table/worker/IcebergTableManager.java