无法执行Sqoop导入

拉胡尔·科鲁里(Rahul Kolluri)

我无法将数据从Mysql导入到Hdfs。我的bashrc和sqoop-env.sh文件很好。我也能够成功运行sqoop list-databases命令。问题与导入命令有关,它引发了outputconnectionfailed异常,请参考以下错误并帮助我:

块引用rahul @ ubuntu:〜$ sqoop import --connect jdbc:mysql:// localhost / rahul --username root --password 123 --table emp -m1 --target-dir / sqoopimport / emp警告:/ usr / lib / hbase不存在!HBase导入将失败。请将$ HBASE_HOME设置为HBase安装的根目录。2009年9月14日01:22:45 WARN工具。BaseSqoopTool:在命令行上设置密码不安全。考虑改用-P。2009年9月14日01:22:45信息管理器。MySQLManager:准备使用MySQL流式结果集。14/09/09 01:22:45 INFO工具.CodeGenTool:开始生成代码14/09/09 01:22:45 INFO manager.SqlManager:执行SQL语句:SELECT t。* FROM empAS t LIMIT 1 14/09 / 09 01:22:45 INFO manager.SqlManager:执行SQL语句:SELECT t。* FROMempAS t LIMIT 1 14/09/09 01:22:45信息orm.CompilationManager:HADOOP_MAPRED_HOME是/ usr / local / hadoop注意:/tmp/sqoop-rahul/compile/a81597835880664d34a2ff0e4c7b9b33/emp.java使用或覆盖不推荐使用的API。注意:有关详细信息,请使用-Xlint:deprecation重新编译。2009年9月14日01:22:46信息orm.CompilationManager:编写jar文件:/tmp/sqoop-rahul/compile/a81597835880664d34a2ff0e4c7b9b33/emp.jar 14/09/09 01:22:46 WARN manager.MySQLManager:看起来就像您从mysql导入一样。2009年9月14日01:22:46 WARN manager.MySQLManager:此传输可以更快!使用--direct 14/09/09 01:22:46 WARN manager.MySQLManager:选项可以执行特定于MySQL的快速路径。14/09/09 01:22:46 INFO manager.MySQLManager:设置零DATETIME行为以convertToNull(mysql)14/09/09 01:22:46 INFO mapreduce.ImportJobBase:开始导入emp 14/09/09 01: 22:

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序尚未收到来自服务器的任何数据包。在org.apache.hadoop.util.ReflectionUtils.setConf(ReflectionUtils.java:62)在org.apache.hadoop.util.ReflectionUtils.setConf(ReflectionUtils.java:62)在org.apache.hadoop.util.ReflectionUtils org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:722)的org.apache.hadoop.mapred.MapTask.run(MapTask.java:364)的.newInstance(ReflectionUtils.java:117)。 apache.hadoop.mapred.Child $ 4.run(Child.java:255)at org.apache上javax.security.auth.Subject.doAs(Subject.java:415)上的java.security.AccessController.doPrivileged(Native Method) org.apache.hadoop.mapred.Child.main(Child.java:249)上的.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190)由以下原因引起:java.lang.RuntimeException:com.mysql.jdbc。

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序尚未收到来自服务器的任何数据包。在org.apache.sqoop.mapreduce.db.DBInputFormat.setConf(DBInputFormat.java:162)处org.apache.sqoop.mapreduce.db.DBInputFormat.getConnection(DBInputFormat.java:193)...另外9个原因由: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:通信链接失败

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序尚未收到来自服务器的任何数据包。在java.lang.java.sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)在sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) .newInstance(Constructor.java:526)位于com.mysql.jdbc.Util.handleNewInstance(Util.java:411)位于com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1121)位于com.mysql.jdbc位于com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2479)处的MysqlIO。(MysqlIO.java:355)位于com.mysql.jdbc处的com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2516)处的MysqlIO。 ConnectionImpl.createNewIO(ConnectionImpl.java:

14/09/09 01:22:54 WARN mapred.JobClient:错误读取任务outputConnection被拒绝14/09/09 01:22:54 WARN mapred.JobClient:错误读取任务outputConnection被拒绝14/09/09 01:22:59 INFO mapred.JobClient:任务ID:try_201409090100_0003_m_000000_1,状态:FAILED java.lang.RuntimeException:java.lang.RuntimeException:com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:通信链接失败

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序尚未收到来自服务器的任何数据包。在org.apache.hadoop.util.ReflectionUtils.setConf(ReflectionUtils.java:62)在org.apache.hadoop.util.ReflectionUtils.setConf(ReflectionUtils.java:62)在org.apache.hadoop.util.ReflectionUtils org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:722)的org.apache.hadoop.mapred.MapTask.run(MapTask.java:364)的.newInstance(ReflectionUtils.java:117)。 apache.hadoop.mapred.Child $ 4.run(Child.java:255)at org.apache上javax.security.auth.Subject.doAs(Subject.java:415)上的java.security.AccessController.doPrivileged(Native Method) org.apache.hadoop.mapred.Child.main(Child.java:249)上的.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190)由以下原因引起:java.lang.RuntimeException:com.mysql.jdbc。

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序尚未收到来自服务器的任何数据包。在org.apache.sqoop.mapreduce.db.DBInputFormat.setConf(DBInputFormat.java:162)处org.apache.sqoop.mapreduce.db.DBInputFormat.getConnection(DBInputFormat.java:193)...另外9个原因由: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:通信链接失败

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序尚未收到来自服务器的任何数据包。在java.lang.java.sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)在sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) .newInstance(Constructor.java:526)位于com.mysql.jdbc.Util.handleNewInstance(Util.java:411)位于com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1121)位于com.mysql.jdbc位于com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2479)处的MysqlIO。(MysqlIO.java:355)位于com.mysql.jdbc处的com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2516)处的MysqlIO。 ConnectionImpl.createNewIO(ConnectionImpl.java:

14/09/09 01:22:59 WARN mapred.JobClient:错误读取任务outputConnection被拒绝14/09/09 01:22:59 WARN mapred.JobClient:错误读取任务outputConnection被拒绝14/09/09 01:23:03 INFO mapred.JobClient:任务ID:try_201409090100_0003_m_000000_2,状态:FAILED java.lang.RuntimeException:java.lang.RuntimeException:com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序在org.org.apache.hadoop.util.ReflectionUtils.setConf(ReflectionUtils.java:62)处的org.apache.sqoop.mapreduce.db.DBInputFormat.setConf(DBInputFormat.java:167)处未收到任何数据包。 org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:722)上的apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:117)在org.apache.hadoop.mapred.MapTask.run(MapTask。 org.apache.hadoop.mapred.Child $ 4.run(Child.java:255)处java.security.AccessController.doPrivileged(Native Method)处javax.security.auth.Subject.doAs(Subject.java) :415),位于org.apache.hadoop.mapred.Child.main(Child.java:249),位于org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190),原因:java.lang.RuntimeException: com.mysql.jdbc.exceptions.jdbc4。

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序在org.apache.sqoop.mapreduce.db.DBInputFormat.setConf(DBInputFormat.java:162)的org.apache.sqoop.mapreduce.db.DBInputFormat.getConnection(DBInputFormat.java:193)处尚未收到任何数据包。 .. 9更多原因:com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:通信链接失败

成功发送到服务器的最后一个数据包是在0毫秒前。驱动程序尚未在sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpljava:sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)在sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)处接收到任何数据包。 com.mysql.jdbc.Util.handleNewInstance(Util.java:411)处com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1121)处的java.lang.reflect.Constructor.newInstance(Constructor.java:526)在com.mysql.jdbc.MysqlIO。(MysqlIO.java:355)在com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2479)在com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2516)在com处的com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2301)处。

14/09/09 01:23:03 WARN mapred.JobClient:错误读取任务outputConnection被拒绝14/09/09 01:23:03 WARN mapred.JobClient:错误读取任务outputConnection被拒绝14/09/09 01:23:09 INFO mapred.JobClient:作业完成:job_201409090100_0003 14/09/09 01:23:09 INFO mapred.JobClient:计数器:6 14/09/09 01:23:09 INFO mapred.JobClient:作业计数器14/09/09 01 :23:09 INFO mapred.JobClient:SLOTS_MILLIS_MAPS = 20325 14/09/09 01:23:09 INFO mapred.JobClient:预留时隙(ms)= 14/09/09 01:23后,所有用户花费的总时间减少了等待时间: 09 INFO mapred.JobClient:
保留位置(ms)= 0后所有地图等待的总时间(ms)= 0 14/09/09 01:23:09 INFO mapred.JobClient:已启动的地图任务= 4 14/09/09 01:23:09 INFO mapred.JobClient: SLOTS_MILLIS_REDUCES = 0 14/09/09 01:23:09 INFO mapred.JobClient:失败的地图任务= 1 14/09/09 01:23:09 INFO mapreduce.ImportJobBase:在23.174秒(0字节/秒)中传输了0字节14/09/09 01:23:09 INFO mapreduce.ImportJobBase:检索了0条记录。2009年9月14日01:23:09错误工具。导入工具:导入期间出错:导入作业失败!块引用

拉胡尔·科鲁里(Rahul Kolluri)

我修好了它。问题是我在import语句中使用了localhost,因为sql在同一系统中运行。当我使用实际IP而不是本地主机时。然后它就像一个魅力。

我也使用root用户名和密码连接到sql。由于某种原因它不起作用。因此,我创建了另一个用户并授予了该用户所有特权。

将所有特权授予员工。*通过“密码”标识为“ sqoopuser” @'%';

错误:sqoop导入--connect jdbc:mysql:// localhost / rahul-用户名root-密码123 --table emp -m1 --target-dir / sqoopimport / emp

更正:sqoop导入--connect jdbc:mysql://192.168.202.139:3306 / rahul-用户名sqoopuser-密码123 --table emp -m1 --target-dir / sqoopimport / emp

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

无法执行Sqoop导入

来自分类Dev

导入脚本中的功能无法执行

来自分类Dev

Android Studio:导入图像时无法执行重构

来自分类Dev

导入pyodbc时无法执行.pyw文件?

来自分类Dev

需要导入邮件但无法执行 Evolution

来自分类Dev

无法执行测试

来自分类Dev

无法执行缺席

来自分类Dev

无法执行Cardview

来自分类Dev

无法执行表格

来自分类Dev

SoapExtension无法执行

来自分类Dev

无法执行查询

来自分类Dev

无法执行孩子

来自分类Dev

无法执行onClick

来自分类Dev

无法执行测试

来自分类Dev

无法执行“ removeChild”

来自分类Dev

无法执行 segue

来自分类Dev

无法执行 lsusb

来自分类Dev

无法执行 ReactiveCommand

来自分类Dev

无法执行警报

来自分类Dev

项目内的相对导入导致“ SystemError:父模块”未加载,无法执行相对导入”

来自分类Dev

项目内的相对导入导致“ SystemError:父模块”未加载,无法执行相对导入”

来自分类Dev

导入 ..<module> 时“未加载父模块,无法执行相对导入”

来自分类Dev

无法执行“ pip安装版本”并显示Python导入错误-ImportError:无法导入名称“ izip_longest”

来自分类Dev

多个查询无法执行

来自分类Dev

无法执行BigInteger的添加

来自分类Dev

无法执行servlet代码

来自分类Dev

无法执行休眠查询

来自分类Dev

iPhone无法执行“ SBSLaunchApplicationWithIdentifier”

来自分类Dev

MyScene无法执行操作