diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java
index 9a33df3a4..73c734178 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java
@@ -171,7 +171,7 @@ public class AvroSchemaConverter {
   /**
    * Converts Flink SQL {@link LogicalType} (can be nested) into an Avro schema.
    *
-   * <p>The "{rowName}_" is used as the nested row type name prefix in order to generate the right
+   * <p>The "{rowName}." is used as the nested row type name prefix in order to generate the right
    * schema. Nested record type that only differs with type name is still compatible.
    *
    * @param logicalType logical type
@@ -263,7 +263,7 @@ public class AvroSchemaConverter {
           LogicalType fieldType = rowType.getTypeAt(i);
           SchemaBuilder.GenericDefault<Schema> fieldBuilder =
               builder.name(fieldName)
-                  .type(convertToSchema(fieldType, rowName + "_" + fieldName));
+                  .type(convertToSchema(fieldType, rowName + "." + fieldName));
 
           if (fieldType.isNullable()) {
             builder = fieldBuilder.withDefault(null);