[HUDI-6222] ParquetSchemaConverter shoud always convert the Map key type as not nullable (#8728)
diff --git a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java
index 7cd7c30..8bd1a84 100644
--- a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java
+++ b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java
@@ -650,7 +650,7 @@
.addField(
Types
.repeatedGroup()
- .addField(convertToParquetType("key", keyType, repetition))
+ .addField(convertToParquetType("key", keyType, Type.Repetition.REQUIRED))
.addField(convertToParquetType("value", valueType, repetition))
.named("key_value"))
.named(name);
diff --git a/hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/io/storage/row/parquet/TestParquetSchemaConverter.java b/hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/io/storage/row/parquet/TestParquetSchemaConverter.java
index 3d5012b..9e07edb 100644
--- a/hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/io/storage/row/parquet/TestParquetSchemaConverter.java
+++ b/hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/io/storage/row/parquet/TestParquetSchemaConverter.java
@@ -56,7 +56,7 @@
+ " }\n"
+ " optional group f_map (MAP) {\n"
+ " repeated group key_value {\n"
- + " optional int32 key;\n"
+ + " required int32 key;\n"
+ " optional binary value (STRING);\n"
+ " }\n"
+ " }\n"
