Reuse already computed schema

trinodb · Sep 19, 2022 · 39e2ff2 · 39e2ff2
1 parent c373dba
commit 39e2ff2
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -1726,7 +1726,7 @@ private void finishWrite(ConnectorSession session, IcebergTableHandle table, Col
         for (CommitTaskData task : commitTasks) {
             PartitionSpec partitionSpec = PartitionSpecParser.fromJson(schema, task.getPartitionSpecJson());
             Type[] partitionColumnTypes = partitionSpec.fields().stream()
-                    .map(field -> field.transform().getResultType(icebergTable.schema().findType(field.sourceId())))
+                    .map(field -> field.transform().getResultType(schema.findType(field.sourceId())))
                     .toArray(Type[]::new);
             switch (task.getContent()) {
                 case POSITION_DELETES: