lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-4259] Flink create avro schema not conformance to standards (#5878)

Browse Source 
* flink create avro schema not conformance to standards

Co-authored-by: 854194341@qq.com <loukey_7821>
This commit is contained in:
luokey
2022-06-20 15:41:23 +08:00
committed by GitHub
parent d7facb8cb8
commit 7c6bedff25
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java
View File

@@ -171,7 +171,7 @@ public class AvroSchemaConverter {
/** /**
* Converts Flink SQL {@link LogicalType} (can be nested) into an Avro schema. * 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. * schema. Nested record type that only differs with type name is still compatible.
* *
* @param logicalType logical type * @param logicalType logical type
@@ -263,7 +263,7 @@ public class AvroSchemaConverter {
LogicalType fieldType = rowType.getTypeAt(i); LogicalType fieldType = rowType.getTypeAt(i);
SchemaBuilder.GenericDefault<Schema> fieldBuilder = SchemaBuilder.GenericDefault<Schema> fieldBuilder =
builder.name(fieldName) builder.name(fieldName)
.type(convertToSchema(fieldType, rowName + "_" + fieldName)); .type(convertToSchema(fieldType, rowName + "." + fieldName));
if (fieldType.isNullable()) { if (fieldType.isNullable()) {
builder = fieldBuilder.withDefault(null); builder = fieldBuilder.withDefault(null);