2017-07-26 1 views
0

J'ai 2 tables VB_B2B_INN_201611_201705_7 que j'importe à adhoc_mn_client_inn_201611_201705 et EVKUZMIN_B2B_CHURN_BAN_SEGMENT qui devrait aller à evkuzmin_b2b_churn_ban_segment.l'importation sqoop fonctionne avec une table, mais pas avec l'autre

Le script dans les deux cas est

sqoop import \ 
-Dmapreduce.job.queuename=adhoc \ 
--connect jdbc:oracle:thin:secret/[email protected]//biistst1:1521/UATR15 \ 
--table table_name-m 1 \ 
--target-dir /apps/hive/warehouse/arstel.db/directory\ 
--delete-target-dir \ 
--fields-terminated-by '\t' 

Ici, je remplacerai table name avec le nom de table Oracle et directory avec répertoire HDFS. J'ai vérifié les deux tables dans Oracle, ils ont des données en eux. Pourtant, l'importation de VB_B2B_INN_201611_201705_7 fonctionne et de EVKUZMIN_B2B_CHURN_BAN_SEGMENT ne fonctionne pas.

Je n'obtiens aucune erreur pour la deuxième table. Juste

INFO mapreduce.ImportJobBase: Transferred 0 bytes in 38.2422 seconds (0 bytes/sec) 
INFO mapreduce.ImportJobBase: Retrieved 0 records. 

Et un fichier vide dans le répertoire evkuzmin_b2b_churn_ban_segment.

Répondre

0

Je ne savais pas que je devais exécuter commit; après avoir inséré des données dans EVKUZMIN_B2B_CHURN_BAN_SEGMENT en premier. Après que j'ai fait tout a fonctionné.