2017-10-17 17 views
0

Je dois écrire un script d'importation scoop qui tire certaines colonnes d'une donnée la_crime seulement de l'année 2016 Mon script est ci-dessous "Sqoop Import: Commande --password: commande non trouvée, --table: commande non trouvée

sqoop import \ 
--connect jdbc:mysql://XXXXXXXXXXX \ 
--driver com.mysql.jdbc.Driver \ 
--username XXXX \ 
--password XXXX \ 
--table la_crime \ 
--query "SELECT DR_NUMBER,DATE_REPORTED,DATE_OCCURED,TIME_OCCURED,AREA_ID,AREA_N AME,REPORTING_DISTRICT,CRIME_CODE,CRIME_CODE_DESC,VICTIM_AGE,VICTIM _GENDER,VICTIM_DESCENT,ADDRESS,CROSS_STREET,AUTO_ID FROM la_crime WHERE\$YEAR=2016\ 
--target-dir /user/sqoop_script \ 
-m 1 

Pourriez-vous me dire si mon code est erroné quelque part Quels changements dois-je faire

Répondre

0

vous peut utiliser la syntaxe suivante pour importer:?

importation Sqoop \

--connect jdbc: mysql: // localhost/votre_base_de_données \

--driver com.mysql.jdbc.Driver \

--username XXXX \

--password XXXX \

la_crime --table \

--query « SELECT DR_NUMBER, DATE_REPORTED, DATE_OCCURED, TIME_OCCURED, area_id, AREA_N AME, REPORTING_DISTRICT, CRIME_CODE, CRIME_CODE_DESC, VICTIM_AGE, V ICTIM _gender, VICTIM_DESCENT, ADRESSE, CROSS_STREET, AUTO_ID DE la_crime OU $ ANNEE = 2016' \

--target-dir/user/sqoop_script \

-m 1

Pour plus de détails, reportez-vous « Sqoop User Guide ".

0

La commande que vous essayez a des problèmes dans l'option query, vous devez d'abord fermer les guillemets à la fin. Deuxièmement, il me semble bizarre que vous utilisiez une variable pour spécifier la colonne pour filtrer l'année.

Troisièmement, si vous utilisez l'option query il est obligatoire d'inclure le jeton $CONDITIONS et puisque vous utilisez des guillemets doubles pour émettre la requête que vous devez \$CONDITIONS au lieu de simplement $CONDITIONS pour interdire votre shell de le traiter comme une coquille variable. En outre, si vous utilisez l'option query, vous ne devez pas utiliser l'option table.

Je pense que ce serait la commande que vous recherchez:

sqoop import \ 
--connect jdbc:mysql://XXXXXXXXXXX \ 
--driver com.mysql.jdbc.Driver \ 
--username XXXX \ 
--password XXXX \ 
--query "SELECT DR_NUMBER,DATE_REPORTED,DATE_OCCURED,TIME_OCCURED,AREA_ID,AREA_N AME,REPORTING_DISTRICT,CRIME_CODE,CRIME_CODE_DESC,VICTIM_AGE,VICTIM _GENDER,VICTIM_DESCENT,ADDRESS,CROSS_STREET,AUTO_ID FROM la_crime WHERE YEAR = 2016 AND $CONDITIONS" \ 
--target-dir /user/sqoop_script \ 
-m 1