sqoop无法从查询中列出列

8wigbo56  于 2021-06-04  发布在  Sqoop
关注(0)|答案(1)|浏览(373)

我从sqoop对mysql数据库执行了这个简单的命令(4.1.22-standard-log)
sqoop导入--连接jdbc:mysql://测试。ddc:3306/test --表“foo”--用户名测试--密码栏--配置单元表test.foo--作为avrodatafile--目标目录/user/admin/foo
我已经抄了 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)
gg0vcinb

gg0vcinb1#

我能解决这个问题。上面缺少驱动程序参数,这是导致问题的原因。下面的命令起作用了

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

相关问题