xiarixiaoyao commented on PR #3391:
URL: https://github.com/apache/hudi/pull/3391#issuecomment-1275873422
@cdmikechen
thanks for your effort,
first of all, i agree with your modification, so i give approve for this pr.
our product env is hive3, we solve this problem by modfiy
HoodieRealtimeRecordReaderUtils.avroToArrayWritable
```
case LONG:
if (supportTimestamp
&& schema.getLogicalType() != null
&& schema.getLogicalType().getName().equals("timestamp-micros"))
{
// TODO: Here we use hive interface to transform long to timestamp
with local timezone.
// Notice that hive support UTC and local timezone, but here we
only support local
// timezone.
Timestamp timestamp = ParquetTimestampUtils.getTimestamp((Long)
value, LogicalTypeAnnotation.TimeUnit.MICROS, true);
return new TimestampWritableV2(timestamp);
}
return new LongWritable((Long) value);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
