Запрос импорта Sqoop не работает в действии OOZIE sqoop - PullRequest
Новая
       31

Запрос импорта Sqoop не работает в действии OOZIE sqoop

0 голосов
/ 15 апреля 2019

Я пытаюсь импортировать данные из MySQL в куст. Имя столбца в таблице содержит пробел. Запрос импорта Sqoop работает на терминале, но когда я использую тот же запрос в действии sqoop рабочего процесса Hue Oozie, я получаю сообщение об ошибке. 

> desc person;
+-------------+--------------+------+-----+---------+-------+
| Field       | Type         | Null | Key | Default | Extra |
+-------------+--------------+------+-----+---------+-------+
| person id   | int(11)      | YES  |     | NULL    |       |
| person name | varchar(255) | YES  |     | NULL    |       |
+-------------+--------------+------+-----+---------+-------+

Обратите внимание на пробел в обеих колонках выше.

Запрос импорта Sqoop, работающий на терминале 

> sqoop import --connect jdbc:mysql://localhost/prateek_temp --username root --password cloudera --query "select p.\`person id\` from person p where p.\`person id\` = 1 and \$CONDITIONS" --hive-import -split-by "p.\`person id\`" --hive-database prateek_tmp --hive-table person --target-dir /user/cloudera/person_tmp -m 1

когда я использую запрос выше в действии oozie sqoop, используя HUE, я получаю ошибку ниже. 

2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: person
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: p
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: where
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: p.\`person
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: id\`
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: =
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: 1
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: and
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: \$CONDITIONS"
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: --hive-import
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: -split-by
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: "p.\`person
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: id\`"
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: --hive-database
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: prateek_tmp
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: --hive-table
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: person_1
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: --target-dir
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: /user/cloudera/person_tmp
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: -m
2019-04-14 21:09:40,615 [main] ERROR org.apache.sqoop.tool.BaseSqoopTool  - Unrecognized argument: 1
...