2016-03-08 78 views
0

我从sqoop执行这个简单的命令对MySQL数据库(4.1.22标准日志)Sqoop无法列出从查询

sqoop进口--connect JDBC列:mysql的://test.ddc:3306 /测试--table “foo” 的--username测试--password酒吧--hive表test.foo --as-avrodatafile --target-DIR /用户/管理员/富

我抄mysql-connector-java-5.1.31-bin.jar/opt/cloudera/parcels/CDH-5.4.1-1.cdh5.4.1.p0.6/lib/sqoop/lib/

我得到这个错误

16/03/08 21:55:56 INFO manager.SqlManager: Executing SQL statement: SELECT t.* FROM `accessory` AS t LIMIT 1 
16/03/08 21:55:56 ERROR manager.CatalogQueryManager: Failed to list columns from query: SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = (SELECT SCHEMA()) AND TABLE_NAME = 'foo' 
com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '()) AND TABLE_NAME = 'foo'' at line 1 
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) 
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 
    at java.lang.reflect.Constructor.newInstance(Constructor.java:526) 
    at com.mysql.jdbc.Util.handleNewInstance(Util.java:408) 
    at com.mysql.jdbc.Util.getInstance(Util.java:383) 

回答

0

我能解决这个问题。上面的驱动程序参数丢失,并导致该问题。下面的命令工作

sqoop import --connect jdbc:mysql://test.ddc:3306/test --table "foo" --driver 
com.mysql.jdbc.Driver --username test --password bar --hive-table test.foo -- 
as-avrodatafile --target-dir /user/admin/foo