This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new e1741ddc7d9 [MINOR] Fix typo for method in AvroSchemaConverter (#8306)
e1741ddc7d9 is described below
commit e1741ddc7d97989808f0f34f3f12e0feb91aae73
Author: Kunni <[email protected]>
AuthorDate: Wed Mar 29 10:49:21 2023 +0800
[MINOR] Fix typo for method in AvroSchemaConverter (#8306)
---
.../src/main/java/org/apache/hudi/util/AvroSchemaConverter.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 925819c871e..44253e37329 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
@@ -301,7 +301,7 @@ public class AvroSchemaConverter {
LogicalTypes.decimal(decimalType.getPrecision(),
decimalType.getScale())
.addToSchema(SchemaBuilder
.fixed(String.format("%s.fixed", rowName))
-
.size(computeMinBytesForDecimlPrecision(decimalType.getPrecision())));
+
.size(computeMinBytesForDecimalPrecision(decimalType.getPrecision())));
return nullable ? nullableSchema(decimal) : decimal;
case ROW:
RowType rowType = (RowType) logicalType;
@@ -377,7 +377,7 @@ public class AvroSchemaConverter {
: Schema.createUnion(SchemaBuilder.builder().nullType(), schema);
}
- private static int computeMinBytesForDecimlPrecision(int precision) {
+ private static int computeMinBytesForDecimalPrecision(int precision) {
int numBytes = 1;
while (Math.pow(2.0, 8 * numBytes - 1) < Math.pow(10.0, precision)) {
numBytes += 1;