lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1662] Fix hive date type conversion for mor table (#2634)

Browse Source
This commit is contained in:
xiarixiaoyao
2021-03-08 12:16:13 +08:00
committed by GitHub
parent 5cf2f2618b
commit 02073235c3
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeRecordReaderUtils.java
View File

@@ -33,6 +33,7 @@ import org.apache.avro.generic.GenericRecord;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hive.serde2.io.DoubleWritable; import org.apache.hadoop.hive.serde2.io.DoubleWritable;
import org.apache.hadoop.hive.serde2.io.DateWritable;
import org.apache.hadoop.hive.serde2.io.HiveDecimalWritable; import org.apache.hadoop.hive.serde2.io.HiveDecimalWritable;
import org.apache.hadoop.hive.serde2.typeinfo.DecimalTypeInfo; import org.apache.hadoop.hive.serde2.typeinfo.DecimalTypeInfo;
import org.apache.hadoop.hive.serde2.typeinfo.HiveDecimalUtils; import org.apache.hadoop.hive.serde2.typeinfo.HiveDecimalUtils;
@@ -166,6 +167,9 @@ public class HoodieRealtimeRecordReaderUtils {
case BYTES: case BYTES:
return new BytesWritable(((ByteBuffer)value).array()); return new BytesWritable(((ByteBuffer)value).array());
case INT: case INT:
if (schema.getLogicalType() != null && schema.getLogicalType().getName().equals("date")) {
return new DateWritable((Integer) value);
}
return new IntWritable((Integer) value); return new IntWritable((Integer) value);
case LONG: case LONG:
return new LongWritable((Long) value); return new LongWritable((Long) value);