lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] fix AvroSchemaConverter duplicate branch in 'switch' (#5813)

Browse Source
This commit is contained in:
sandyfog
2022-06-13 10:55:24 +08:00
committed by GitHub
parent 5aaac21d1d
commit c82e3462e3
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -71,6 +71,8 @@ public class AvroSchemaConverter {
} }
return DataTypes.ROW(fields).notNull(); return DataTypes.ROW(fields).notNull();
case ENUM: case ENUM:
case STRING:
// convert Avro's Utf8/CharSequence to String
return DataTypes.STRING().notNull(); return DataTypes.STRING().notNull();
case ARRAY: case ARRAY:
return DataTypes.ARRAY(convertToDataType(schema.getElementType())).notNull(); return DataTypes.ARRAY(convertToDataType(schema.getElementType())).notNull();
@@ -110,9 +112,6 @@ public class AvroSchemaConverter {
} }
// convert fixed size binary data to primitive byte arrays // convert fixed size binary data to primitive byte arrays
return DataTypes.VARBINARY(schema.getFixedSize()).notNull(); return DataTypes.VARBINARY(schema.getFixedSize()).notNull();
case STRING:
// convert Avro's Utf8/CharSequence to String
return DataTypes.STRING().notNull();
case BYTES: case BYTES:
// logical decimal type // logical decimal type
if (schema.getLogicalType() instanceof LogicalTypes.Decimal) { if (schema.getLogicalType() instanceof LogicalTypes.Decimal) {