hadoop - 从配置单元到 teradata 的 Sqoop 导出不适用于时间戳字段

Question

我正在尝试将一个文件从配置单元中导出一个文件，其中一个字段作为时间戳 ('2016-05-21 02:00:00') 到 teradata。teradata 中的数据类型是 timestamp(0)，可以期待类似的格式。

当我尝试使用 sqoop 导出它时，它给出了字符串到时间戳的转换错误。任何解决方法都将大有帮助。

注意:

• String 到 teradata 中的 Varchar(256) 工作。
• String 到 teradata 中的 timestamp(0) 失败。
• Timestamp in hive to timestamp(0) in teradata 失败。

日志:

16/07/12 12:24:20 INFO mapreduce.Job:  map 0% reduce 0%
16/07/12 12:24:27 INFO mapreduce.Job: Task Id : attempt_1467306662019_8607_m_000001_0, Status : FAILED
Error: java.lang.RuntimeException: Unparseable date: "2016-07-11 22:36:55"
    at com.teradata.connector.common.converter.ConnectorDataTypeConverter$StringFMTTZToTimestampTZ.convert(ConnectorDataTypeConverter.java:1679)
    at com.teradata.connector.teradata.converter.TeradataConverter.convert(TeradataConverter.java:143)
    at com.teradata.connector.common.ConnectorOutputFormat$ConnectorFileRecordWriter.write(ConnectorOutputFormat.java:106)
    at com.teradata.connector.common.ConnectorOutputFormat$ConnectorFileRecordWriter.write(ConnectorOutputFormat.java:65)
    at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.write(MapTask.java:658)
    at org.apache.hadoop.mapreduce.task.TaskInputOutputContextImpl.write(TaskInputOutputContextImpl.java:89)
    at org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.write(WrappedMapper.java:112)
    at com.teradata.connector.common.ConnectorMMapper.map(ConnectorMMapper.java:129)
    at com.teradata.connector.common.ConnectorMMapper.run(ConnectorMMapper.java:117)
    at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:787)
    at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
    at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:168)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:415)
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1709)
    at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:162)

Answer 1

Teradata 列应采用“TIMESTAMP(0) WITH TIME ZONE”格式。它对我来说工作正常。