sqoop:通信链路故障

uqdfh47h  于 2021-07-13  发布在  Hadoop
关注(0)|答案(0)|浏览(326)

当我通过sqoop连接到mysql时,出现以下错误
请帮助我确定这个问题的原因是什么,或者我在命令中遗漏了什么。谢谢!

  1. SERVER DETAILS :
  2. HOSTNAME: SUSDAY1110
  3. PORT: 1433
  4. IP Address: 193.126.45.149
  5. Instance: GMAGHDEV
  6. DATABASE: GMAGH
  1. sqoop import --connect jdbc:mysql://193.126.45.149:1433/GMAGH --table ALL_LOB --username root11 --password 'asdad!34' --target-dir /user/sqoop/data/ALL_LOB -m 1

运行命令时出现以下错误:

  1. 21/03/19 09:34:36 INFO sqoop.Sqoop: Running Sqoop version: 1.4.6.2.6.5.1153-2
  2. 21/03/19 09:34:36 WARN tool.BaseSqoopTool: Setting your password on the command-line is insecure. Consider using -P instead.
  3. 21/03/19 09:34:37 INFO manager.MySQLManager: Preparing to use a MySQL streaming resultset.
  4. 21/03/19 09:34:37 INFO tool.CodeGenTool: Beginning code generation
  5. 21/03/19 09:34:37 ERROR manager.SqlManager: Error executing statement: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure
  6. The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
  7. com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure
  8. The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
  9. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  10. at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
  11. at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  12. at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
  13. at com.mysql.jdbc.Util.handleNewInstance(Util.java:411)
  14. at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1121)
  15. at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:357)
  16. at com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2484)
  17. at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2521)
  18. at com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2306)
  19. at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:839)
  20. at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:49)
  21. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  22. at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
  23. at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  24. at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
  25. at com.mysql.jdbc.Util.handleNewInstance(Util.java:411)
  26. at com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:421)
  27. at com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:350)
  28. at java.sql.DriverManager.getConnection(DriverManager.java:664)
  29. at java.sql.DriverManager.getConnection(DriverManager.java:247)
  30. at org.apache.sqoop.manager.SqlManager.makeConnection(SqlManager.java:904)
  31. at org.apache.sqoop.manager.GenericJdbcManager.getConnection(GenericJdbcManager.java:52)
  32. at org.apache.sqoop.manager.SqlManager.execute(SqlManager.java:763)
  33. at org.apache.sqoop.manager.SqlManager.execute(SqlManager.java:786)
  34. at org.apache.sqoop.manager.SqlManager.getColumnInfoForRawQuery(SqlManager.java:289)
  35. at org.apache.sqoop.manager.SqlManager.getColumnTypesForRawQuery(SqlManager.java:260)
  36. at org.apache.sqoop.manager.SqlManager.getColumnTypes(SqlManager.java:246)
  37. at org.apache.sqoop.manager.ConnManager.getColumnTypes(ConnManager.java:328)
  38. at org.apache.sqoop.orm.ClassWriter.getColumnTypes(ClassWriter.java:1853)
  39. at org.apache.sqoop.orm.ClassWriter.generate(ClassWriter.java:1653)
  40. at org.apache.sqoop.tool.CodeGenTool.generateORM(CodeGenTool.java:107)
  41. at org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:488)
  42. at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:615)
  43. at org.apache.sqoop.Sqoop.run(Sqoop.java:147)
  44. at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:76)
  45. at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:183)
  46. at org.apache.sqoop.Sqoop.runTool(Sqoop.java:225)
  47. at org.apache.sqoop.Sqoop.runTool(Sqoop.java:234)
  48. at org.apache.sqoop.Sqoop.main(Sqoop.java:243)
  49. Caused by: java.net.ConnectException: Connection refused (Connection refused)
  50. at java.net.PlainSocketImpl.socketConnect(Native Method)
  51. at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
  52. at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
  53. at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
  54. at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
  55. at java.net.Socket.connect(Socket.java:589)
  56. at java.net.Socket.connect(Socket.java:538)
  57. at java.net.Socket.<init>(Socket.java:434)
  58. at java.net.Socket.<init>(Socket.java:244)
  59. at com.mysql.jdbc.StandardSocketFactory.connect(StandardSocketFactory.java:259)
  60. at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:307)
  61. ... 33 more
  62. 21/03/19 09:34:37 ERROR tool.ImportTool: Encountered IOException running import job: java.io.IOException: No columns to generate for ClassWriter
  63. at org.apache.sqoop.orm.ClassWriter.generate(ClassWriter.java:1659)
  64. at org.apache.sqoop.tool.CodeGenTool.generateORM(CodeGenTool.java:107)
  65. at org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:488)
  66. at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:615)
  67. at org.apache.sqoop.Sqoop.run(Sqoop.java:147)
  68. at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:76)
  69. at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:183)
  70. at org.apache.sqoop.Sqoop.runTool(Sqoop.java:225)
  71. at org.apache.sqoop.Sqoop.runTool(Sqoop.java:234)
  72. at org.apache.sqoop.Sqoop.main(Sqoop.java:243)

使用单引号内的密码,因为它无法读取后 !asdad!34 . 我还必须包括示例值吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题