lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2756] Fix flink parquet writer decimal type conversion (#3988)

Browse Source
This commit is contained in:
Danny Chan
2021-11-14 08:51:54 +08:00
committed by GitHub
parent 994922a159
commit c2f9094b49
3 changed files with 87 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java
View File

@@ -564,7 +564,7 @@ public class ParquetSchemaConverter {
int scale = ((DecimalType) type).getScale();
int numBytes = computeMinBytesForDecimalPrecision(precision);
return Types.primitive(
PrimitiveType.PrimitiveTypeName.BINARY, repetition)
PrimitiveType.PrimitiveTypeName.FIXED_LEN_BYTE_ARRAY, repetition)
.precision(precision)
.scale(scale)
.length(numBytes)