Imported Ошибка: Указанный идентификатор столбца Дубликат (sqoop)

Question

Запрос:

sqoop import --connect jdbc:mysql://localhost/userdb --username abc --password abc --query 'SELECT e.*,d.* FROM employee e JOIN department d on e.DEPTNO = d.DEPTNO WHERE $CONDITIONS ' --split-by e.DEPTNO --target-dir /output/result;

Ошибка:

Imported Failed: Duplicate Column identifier specified (sqoop)

Answer 1

Это ожидаемое поведение, как вы выбираете все столбцы в запрос, и обе таблицы имеют одинаковый столбец DEPTNO.

выберите все столбцы индивидуально с псевдонимом.

Изменить запрос аналогичным образом:

--query 'SELECT e.col1 as ecol1, e.col2 as ecol2, e.col3 as ecol3, d.col1 as dcol1, d.col2 as dcol2, c.col3 as dcol3 FROM employee e JOIN department d on e.DEPTNO = d.DEPTNO WHERE $CONDITIONS'