我使用 Sqoop 成功地将 oracle 表的临时导入到 Hive 表中。现在我想使用我用于临时导入的确切参数创建并保存一个 Sqoop 作业。
但如果我说:
sqoop job --create myjob --import \
--connect jdbc:mysql://host.port/foo \
--username myUserName \
--password-file file:///myfile.pwd \
--table mytable \
--create-hive-table \
--hive-import \
--hive-database my_hive_db \
--hive-table my_hive_table \
--fields-terminated-by '|' \
--hive-drop-import-delims \
--m 1
我收到一个错误:
19/03/05 14:56:41 ERROR tool.BaseSqoopTool: Error parsing arguments for job:
19/03/05 14:56:41 ERROR tool.BaseSqoopTool: Unrecognized argument: --import
19/03/05 14:56:41 ERROR tool.BaseSqoopTool: Unrecognized argument: --connect
19/03/05 14:56:41 ERROR tool.BaseSqoopTool: Unrecognized argument: jdbc:mysql:@host:port/foo
如果我删除所有 \ 它仍然无法正常工作。
如何使用 Hive 导入的所有必要参数定义 Sqoop 作业?