java - 无法使用Sqoop从Mysql导入表

Question

我在 MySQL 的 demo_poc 数据库的 employee 表中有 5 条记录

192.168.1.126 [机器 1]。

我想将数据导入到hive中

192.168.1.129 [Machine-2] 使用 Sqoop。

我在 Machine-2 上安装了 sqoop 1.4.6。

我试过这样，

sqoop import --connect jdbc:mysql://192.168.1.126:3306/demo_poc 
--username root --password root --table employee -m 10
--hive-import --hive-table demo_poc.address

这是我收到的错误，

16/04/11 16:28:20 INFO tool.CodeGenTool: Beginning code generation 
16/04/11 16:28:21 ERROR manager.SqlManager: Error executing statement: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure 
16/04/11 16:28:21 ERROR tool.ImportTool: Encountered IOException running import job: java.io.IOException: No columns to generate for ClassWriter

任何建议。谢谢。

Answer 1

sqoop-import --connect jdbc:mysql://192.168.1.126:3306/demo_poc --username root --P --table employee -m 1 --hive-import --hive-table demo_poc.employee