From 0094102f21067a19993dbba75783017dfcc06f0b Mon Sep 17 00:00:00 2001 From: "854194341@qq.com" Date: Wed, 15 Jun 2022 22:51:31 +0800 Subject: [PATCH 1/2] flink create avro schema not conformance to standards --- .../src/main/java/org/apache/hudi/util/AvroSchemaConverter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 9a33df3a4d74b..8e068f3d382f6 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 @@ -263,7 +263,7 @@ public static Schema convertToSchema(LogicalType logicalType, String rowName) { LogicalType fieldType = rowType.getTypeAt(i); SchemaBuilder.GenericDefault fieldBuilder = builder.name(fieldName) - .type(convertToSchema(fieldType, rowName + "_" + fieldName)); + .type(convertToSchema(fieldType, rowName + "." + fieldName)); if (fieldType.isNullable()) { builder = fieldBuilder.withDefault(null); From d1a7987e0f653809f135f67c5649ef53fe24ff26 Mon Sep 17 00:00:00 2001 From: "854194341@qq.com" Date: Fri, 17 Jun 2022 01:34:49 +0800 Subject: [PATCH 2/2] flink create avro schema not conformance to standards --- .../src/main/java/org/apache/hudi/util/AvroSchemaConverter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 8e068f3d382f6..73c7341780b4d 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 static Schema convertToSchema(LogicalType schema) { /** * Converts Flink SQL {@link LogicalType} (can be nested) into an Avro schema. * - *

The "{rowName}_" is used as the nested row type name prefix in order to generate the right + *

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