2017-01-11 10 views
0

Я пытаюсь импортировать данные из oracle с помощью запроса свободной формы и вам нужно сохранить временную метку в 24-часовом формате.с использованием 24hr timestamp в sqoop import

sqoop import --connect jdbc:oracle:thin:(server credntials) \ 
--username ***** --password ***** \ 
--query "select emp_uid, emp_name, salary, to_char(create_timestamp, 'YYYY-MM-DD HH24:MI:SS'), to_char(last_sal_update_timestamp, 'YYYY-MM-DD HH24:MI:SS'), coalesce(to_char(last_sal_update_timestamp, 'YYYY-MM-DD HH24:MI:SS'),to_char(create_timestamp, 'YYYY-MM-DD HH24:MI:SS')) as hadoop_import_timestamp from emp.emp_sal where last_sal_update_timestamp < (to_char('2013-01-21 09:16:20', 'YYYY-MM-DD HH24:MI:SS')) and \$CONDITIONS" \ 
--split-by "to_char(hadoop_import_timestamp, 'YYYY-MM-DD HH24:MI:SS')" \ 
--target-dir /user/sal/emp_sal \ 
--map-column-hive CREATE_TIMESTAMP=TIMESTAMP,LAST_SAL_UPDATE_TIMESTAMP=TIMESTAMP,HADOOP_IMPORT_TIMESTAMP=TIMESTAMP \ 
--hive-import \ 
--hive-table empdet.empsal \ 
--hive-drop-import-delims 

Но я получаю неверный номер ошибку при попытке запустить его

+0

пожалуйста, поделитесь журналами ошибок и улая структурой таблицы –

+0

И ОПИСАНИЕ Oracle Table plz –

ответ

0

Это работает, когда разделенные на это с первичным ключом (emp_uid)