从SybaseIQ导入到Hive - java.io.IOException: SQLException in nextKeyValue

Question

当我试图导入一个表到Hive时，我得到了一个奇怪的错误。

查询：

sqoop import  --connect 'jdbc:sybase:Tds:10.100.*.***:5500/DATABASE=****' --driver 'com.sybase.jdbc3.jdbc.SybDriver' --username "****" --password "***" --table dw.dm_court_courttype --direct -m 1 --hive-import --create-hive-table --hive-table DM_court_courtcype --target-dir "/user/hive/warehouse/DM_Court_CourtType" --verbose

错误：

org.apache.sqoop.mapreduce.db.DBRecordReader.nextKeyValue(DBRecordReader.java:277)，org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:565)，org.apache.hadoop.mapreduce.task.MapContextImpl.nextKeyValue(MapContextImpl.java:80)，org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context，nextKeyValue中的SQLExceptionorg.apache.hadoop.mapreduce.Mapper.run(Mapper.java:145)，org.apache.sqoop.mapreduce.AutoProgressMapper.run(AutoProgressMapper.java:64)，org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:796)，org.apache.hadoop.mapred.MapTask.run(MapTask.java:346，.nextKeyValue(WrappedMapper.java:91)在org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:163) at java.security.AccessController.doPrivileged(Native Method)在javax.security.auth.Subject.doAs(Subject.java:415) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1595) at org.apache.hadoop。mapred.YarnChild.main(YarnChild.java:158)，由: com.sybase.jdbc3.jdbc.SybSQLException: SQL错误-131:语法错误“.”引起。在第1行，com.sybase.jdbc3.tds.Tds.a(未知源)，com.sybase.jdbc3.tds.Tds.nextResult(未知源)，com.sybase.jdbc3.tds.TdsCursor.open(未知源)，com.sybase.jdbc3.jdbccom.sybase.jdbc3.jdbc.SybPreparedStatement.executeQuery(Unknown源的.SybStatement.executeQuery(未知源)在org.apache.sqoop.mapreduce.db.DBRecordReader.nextKeyValue(DBRecordReader.java:235)的org.apache.sqoop.mapreduce.db.DBRecordReader.executeQuery(DBRecordReader.java:111)

Answer 1

不要在表名中使用数据库名。

使用--table dm_court_courttype而不是--table dw.dm_court_courttype

试试这个：

sqoop import --connect 'jdbc:sybase:Tds:10.100..:5500/DATABASE=****' --driver 'com.sybase.jdbc3.jdbc.SybDriver' --username "****" --password "*" --table dm_court_courttype --direct -m 1 --hive-import --create-hive-table --hive-table DM_court_courtcype --target-dir "/user/hive/warehouse/DM_Court_CourtType" --verbose