diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMergeTableHandle.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMergeTableHandle.java index 57767288444e..d99cbc166241 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMergeTableHandle.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMergeTableHandle.java @@ -26,7 +26,9 @@ public class IcebergMergeTableHandle private final IcebergWritableTableHandle insertTableHandle; @JsonCreator - public IcebergMergeTableHandle(IcebergTableHandle tableHandle, IcebergWritableTableHandle insertTableHandle) + public IcebergMergeTableHandle( + @JsonProperty("tableHandle") IcebergTableHandle tableHandle, + @JsonProperty("insertTableHandle") IcebergWritableTableHandle insertTableHandle) { this.tableHandle = requireNonNull(tableHandle, "tableHandle is null"); this.insertTableHandle = requireNonNull(insertTableHandle, "insertTableHandle is null"); diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergWritableTableHandle.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergWritableTableHandle.java index f46cf4640309..e25723fdc6ce 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergWritableTableHandle.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergWritableTableHandle.java @@ -47,13 +47,13 @@ public class IcebergWritableTableHandle public IcebergWritableTableHandle( @JsonProperty("name") SchemaTableName name, @JsonProperty("schemaAsJson") String schemaAsJson, - @JsonProperty("partitionSpecsAsJson") Map partitionsSpecsAsJson, + @JsonProperty("partitionsSpecsAsJson") Map partitionsSpecsAsJson, @JsonProperty("partitionSpecId") int partitionSpecId, @JsonProperty("sortOrder") List sortOrder, @JsonProperty("inputColumns") List inputColumns, @JsonProperty("outputPath") String outputPath, @JsonProperty("fileFormat") IcebergFileFormat fileFormat, - @JsonProperty("properties") Map storageProperties, + @JsonProperty("storageProperties") Map storageProperties, @JsonProperty("retryMode") RetryMode retryMode, @JsonProperty("fileIoProperties") Map fileIoProperties) {