You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2023/03/29 02:49:32 UTC
[hudi] branch master updated: [MINOR] Fix typo for method in AvroSchemaConverter (#8306)
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 <ku...@dtstack.com>
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;