From 9e07cebece3b4c8b964ddca2f40053734a392ce2 Mon Sep 17 00:00:00 2001 From: lw0090 Date: Tue, 9 Jun 2020 09:22:06 +0800 Subject: [PATCH] [HUDI-974] Fix fields out of order in MOR mode when using Hive (#1711) --- .../hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java index f1e81a773..4c773d458 100644 --- a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java +++ b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java @@ -80,7 +80,7 @@ class RealtimeUnmergedRecordReader extends AbstractRealtimeRecordReader false, jobConf.getInt(MAX_DFS_STREAM_BUFFER_SIZE_PROP, DEFAULT_MAX_DFS_STREAM_BUFFER_SIZE), record -> { // convert Hoodie log record to Hadoop AvroWritable and buffer GenericRecord rec = (GenericRecord) record.getData().getInsertValue(getReaderSchema()).get(); - ArrayWritable aWritable = (ArrayWritable) avroToArrayWritable(rec, getWriterSchema()); + ArrayWritable aWritable = (ArrayWritable) avroToArrayWritable(rec, getHiveSchema()); this.executor.getQueue().insertRecord(aWritable); }); // Start reading and buffering