diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java index 869e0ea7e9db..2bfe3879d2c2 100644 --- a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java +++ b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java @@ -1120,13 +1120,6 @@ public Optional finishCreateTable( "Table '%s' does not have correct query id set", table); - ImmutableList.Builder columnNames = ImmutableList.builderWithExpectedSize(handle.getInputColumns().size()); - ImmutableMap.Builder columnTypes = ImmutableMap.builderWithExpectedSize(handle.getInputColumns().size()); - for (DeltaLakeColumnHandle column : handle.getInputColumns()) { - columnNames.add(column.getBaseColumnName()); - columnTypes.put(column.getBaseColumnName(), serializeColumnType(NONE, new AtomicInteger(), column.getBaseType())); - } - ColumnMappingMode columnMappingMode = handle.getColumnMappingMode(); String schemaString = handle.getSchemaString(); try {