diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/checkpoint/CheckpointWriter.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/checkpoint/CheckpointWriter.java index 2548462128f4..74c3eaa22fdf 100644 --- a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/checkpoint/CheckpointWriter.java +++ b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/checkpoint/CheckpointWriter.java @@ -457,7 +457,7 @@ private void writeStringMap(BlockBuilder blockBuilder, RowType type, int fieldId mapBuilder.appendNull(); } else { - mapType.getKeyType().writeSlice(mapBuilder, utf8Slice(entry.getValue())); + mapType.getValueType().writeSlice(mapBuilder, utf8Slice(entry.getValue())); } } blockBuilder.closeEntry();