Fix JsonProperty annotation in Iceberg

trinodb · Mar 29, 2024 · 342448c · 342448c
1 parent c8629fc
commit 342448c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
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
@@ -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
@@ -47,13 +47,13 @@ public class IcebergWritableTableHandle
     public IcebergWritableTableHandle(
             @JsonProperty("name") SchemaTableName name,
             @JsonProperty("schemaAsJson") String schemaAsJson,
-            @JsonProperty("partitionSpecsAsJson") Map<Integer, String> partitionsSpecsAsJson,
+            @JsonProperty("partitionsSpecsAsJson") Map<Integer, String> partitionsSpecsAsJson,
             @JsonProperty("partitionSpecId") int partitionSpecId,
             @JsonProperty("sortOrder") List<TrinoSortField> sortOrder,
             @JsonProperty("inputColumns") List<IcebergColumnHandle> inputColumns,
             @JsonProperty("outputPath") String outputPath,
             @JsonProperty("fileFormat") IcebergFileFormat fileFormat,
-            @JsonProperty("properties") Map<String, String> storageProperties,
+            @JsonProperty("storageProperties") Map<String, String> storageProperties,
             @JsonProperty("retryMode") RetryMode retryMode,
             @JsonProperty("fileIoProperties") Map<String, String> fileIoProperties)
     {