Skip to content

Commit b9b24c4

Browse files
committed
fix bug
1 parent f3e44c6 commit b9b24c4

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HiveAvroSerializer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,7 @@ private Object serializeList(ListTypeInfo typeInfo, ListObjectInspector fieldOI,
332332
Schema elementType = schema.getElementType();
333333

334334
for (int i = 0; i < list.size(); i++) {
335-
deserialized.add(i, serialize(listElementTypeInfo, listElementObjectInspector, list.get(i), elementType));
335+
deserialized.add(i, serialize(listElementTypeInfo, listElementObjectInspector, list.get(i), elementType.getField("element").schema()));
336336
}
337337

338338
return deserialized;

hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestBootstrap.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@
116116
public class TestBootstrap extends HoodieClientTestBase {
117117

118118
public static final String TRIP_HIVE_COLUMN_TYPES = "bigint,string,string,string,string,double,double,double,double,"
119-
+ "struct<amount:double,currency:string>,array<struct<element:struct<amount:double,currency:string>>>,boolean";
119+
+ "struct<amount:double,currency:string>,array<struct<amount:double,currency:string>>,boolean";
120120

121121
@TempDir
122122
public java.nio.file.Path tmpFolder;

0 commit comments

Comments
 (0)