Skip to content

Commit 2cd8e80

Browse files
committed
Rebase 2022.12.10 and fix test case error
1 parent 0fb7a3b commit 2cd8e80

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,8 @@ private List<HoodieProducer<ArrayWritable>> getParallelProducers(
106106
scannerBuilder.withLogRecordScannerCallback(record -> {
107107
// convert Hoodie log record to Hadoop AvroWritable and buffer
108108
GenericRecord rec = (GenericRecord) record.getData().getInsertValue(getReaderSchema(), payloadProps).get();
109-
ArrayWritable aWritable = (ArrayWritable) HoodieRealtimeRecordReaderUtils.avroToArrayWritable(rec, getHiveSchema(), isSupportTimestamp());
109+
ArrayWritable aWritable = (ArrayWritable) HoodieRealtimeRecordReaderUtils.avroToArrayWritable(rec, getHiveSchema(),
110+
isSupportTimestamp());
110111
queue.insertRecord(aWritable);
111112
})
112113
.build();

hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/utils/TestHiveAvroSerializer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public void testSerialize() {
8282
ByteBuffer bb = ByteBuffer.wrap(new byte[]{97, 48, 53});
8383
avroRecord.put("col9", bb);
8484
assertTrue(GenericData.get().validate(avroSchema, avroRecord));
85-
ArrayWritable writable = (ArrayWritable) HoodieRealtimeRecordReaderUtils.avroToArrayWritable(avroRecord, avroSchema);
85+
ArrayWritable writable = (ArrayWritable) HoodieRealtimeRecordReaderUtils.avroToArrayWritable(avroRecord, avroSchema, true);
8686

8787
List<Writable> writableList = Arrays.stream(writable.get()).collect(Collectors.toList());
8888
writableList.remove(writableList.size() - 1);

0 commit comments

Comments
 (0)