我试图使用Process("<sqoop command>").!在Scala上运行一个具有-query选项的Sqoop命令,但是它显示了下面描述的一个错误。
如果我用-table而不是--查询,它就像一种魅力。
但是对于我的要求,我需要使用--查询。
它给出的错误是:
ERROR tool.BaseSqoopTool: Error parsing arguments for import:
ERROR tool.BaseSqoopTool: Unrecognized argument: *
ERROR tool.BaseSqoopTool: Unrecognized argument: from 等。
提前感谢
下面的代码在中正常工作。
Process("""sqoop import <queuename> --connect <connection-string-db2> --
username <username> --password <password> --table "<database.table>" --
target-dir <target directory> --delete-target-dir --fields-terminated-by
'\\001' --lines-terminated-by '\\n' --null-string '\\\\N' --null-non-
string '\\\\N' --hive-drop-import-delims -m 1""").! 但是,当我逐个更改-表-查询(并在其中使用任何基本查询,例如"SELECT * FROM DATABASE.TABLE")时,它就不能工作.下面是不能工作的命令:
Process("""sqoop import <queuename> --connect <connection-string-db2> --
username <username> --password <password> --query "SELECT * FROM
DATABASE.TABLE AND \$CONDITIONS" --target-dir <target directory> --
delete-target-dir --fields-terminated-by '\\001' --lines-terminated-by
'\\n' --null-string '\\\\N' --null-non-string '\\\\N' --hive-drop-
import-delims -m 1""").! 发布于 2019-05-27 12:02:46
我想你应该在查询后避开双引号。
https://stackoverflow.com/questions/56073298
复制相似问题