Не удалось импортировать sqoop Невозможно инициализировать кластер - PullRequest
Новая
       4

Не удалось импортировать sqoop Невозможно инициализировать кластер

0 голосов
/ 04 июня 2019

Я новичок в Hadoop и sqoop и пытаюсь импортировать таблицу mySql в Hadoop с помощью sqoop

Я посмотрел на
Невозможно инициализировать исключение кластера при выполнении задания в Hadoop 2 и
Невозможно инициализировать кластер.Пожалуйста, проверьте вашу конфигурацию для mapreduce.framework.name и соответствующих адресов сервера

Однако я не могу понять, как действовать

При выполнении 

sqoop import --connect jdbc:mysql://localhost/crawl_data_stats --username root --password password --table auth_group

Я получаю ошибку 

ERROR tool.ImportTool: Import failed: java.io.IOException: Cannot initialize Cluster. Please check your configuration for mapreduce.framework.name and the correspond server addresses.  
at org.apache.hadoop.mapreduce.Cluster.initialize(Cluster.java:120)  
at org.apache.hadoop.mapreduce.Cluster.<init>(Cluster.java:82)  
at org.apache.hadoop.mapreduce.Cluster.<init>(Cluster.java:75)  
at org.apache.hadoop.mapreduce.Job$9.run(Job.java:1260)  
at org.apache.hadoop.mapreduce.Job$9.run(Job.java:1256)  
at java.security.AccessController.doPrivileged(Native Method)  
at javax.security.auth.Subject.doAs(Subject.java:422)  
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1729)  
at org.apache.hadoop.mapreduce.Job.connect(Job.java:1256)  
at org.apache.hadoop.mapreduce.Job.submit(Job.java:1284)  
at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:1308)  
at org.apache.sqoop.mapreduce.ImportJobBase.doSubmitJob(ImportJobBase.java:200)  
at org.apache.sqoop.mapreduce.ImportJobBase.runJob(ImportJobBase.java:173)  
at org.apache.sqoop.mapreduce.ImportJobBase.runImport(ImportJobBase.java:270)  
at org.apache.sqoop.manager.SqlManager.importTable(SqlManager.java:692)  
at org.apache.sqoop.manager.MySQLManager.importTable(MySQLManager.java:127)  
at org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:520)  
at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:628)  
at org.apache.sqoop.Sqoop.run(Sqoop.java:147)  
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:76)  
at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:183)  
at org.apache.sqoop.Sqoop.runTool(Sqoop.java:234)  
at org.apache.sqoop.Sqoop.runTool(Sqoop.java:243)  
at org.apache.sqoop.Sqoop.main(Sqoop.java:252)
...