我正在尝试将一个部分表从mysql导入hdfs数据库。我尝试了sqoop导入。当我在where子句中只应用一个条件时,它就起作用了。
但当我再添加一个条件时,它会给我一个错误:
Error parsing arguments for import:
查询如下: sqoop import --table accounts --connect jdbc:mysql://localhost/loudacre --username myuser --password mypw --target-dir /homeworks/sqoop/ --where "state='CA'" and "acct_close_dt IS NULL"
1条答案
按热度按时间pdsfdshx1#
尝试使用自由格式查询导入:
sqoop import --table accounts --connect jdbc:mysql://localhost/loudacre --username myuser --password mypw --target-dir /homeworks/sqoop/ --query "select * from accounts where state='CA' and acct_close_dt IS NULL AND \$CONDITIONS"
如果你在写作--query
在单引号(')中使用$CONDITIONS
而不是\$CONDITIONS
按照皮尤的建议检查文件。