it's working now. Thanks for all helping this issue. On Fri, Jul 20, 2012 at 1:46 PM, [email protected] <[email protected]>wrote:
> hi prabhu， > you should make sure that 10.5.114.101:54310<http://10.5.114.101:54310/books> > is the mysql address and port? use mysql -uroot -h10.5.114.101 --port > 54301, can you login to mysql? > > please reference my blog :http//abloz.com, > http://abloz.com/2012/07/20/from-the-mysql-data-into-hive.html > using google translate to translate from Chinese to English. > > Best wishes. > andy zhou > > > 2012/7/17 Rajesh Koilpillai <[email protected]> > >> The above error usually gets thrown if you are unable to access the MySQL >> server while you are trying to import. Are you certain that the MySQL >> server is accessible from the machine in which you are importing. >> >> On Mon, Jul 16, 2012 at 5:51 PM, prabhu k <[email protected]> wrote: >> >>> Hi Users list, >>> >>> While i am trying to import mysql db table to hive, getting following >>> output : >>> >>> command used: >>> >>> bin/sqoop import --connect jdbc:mysql://10.5.114.101:54310/books--verbose >>> -m 1 --username root --hive-overwrite --direct --table authors >>> --hive-import --create-hive-table --hive-table authors >>> --fields-terminated-by '\t' --lines-terminated-by '\n' --append >>> >>> Error: >>> >>> sqoop-1.4.1-incubating__hadoop-0.20# bin/sqoop import --connect >>> jdbc:mysql://10.5.114.101:54310/books --verbose -m 1 --username root >>> --hive-overwrite --direct --table authors --hive-import --create-hive-table >>> --hive-table authors --fields-terminated-by '\t' --lines-terminated-by '\n' >>> --append >>> Warning: /usr/lib/hbase does not exist! HBase imports will fail. >>> Please set $HBASE_HOME to the root of your HBase installation. >>> Warning: $HADOOP_HOME is deprecated. >>> 12/07/16 17:22:30 INFO manager.MySQLManager: Preparing to use a MySQL >>> streaming resultset. >>> 12/07/16 17:22:30 INFO tool.CodeGenTool: Beginning code generation >>> 12/07/16 17:22:30 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 >>> The last packet sent successfully to the server was 0 milliseconds ago. >>> The driver has not received any packets from the server. >>> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native >>> Method) >>> at >>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) >>> at >>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) >>> at >>> java.lang.reflect.Constructor.newInstance(Constructor.java:513) >>> at com.mysql.jdbc.Util.handleNewInstance(Util.java:411) >>> at >>> com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1116) >>> at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:348) >>> at >>> com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2391) >>> at >>> com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2428) >>> at >>> com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2213) >>> at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:797) >>> at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:47) >>> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native >>> Method) >>> at >>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) >>> at >>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) >>> at >>> java.lang.reflect.Constructor.newInstance(Constructor.java:513) >>> at com.mysql.jdbc.Util.handleNewInstance(Util.java:411) >>> at >>> com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:389) >>> at >>> com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:305) >>> at java.sql.DriverManager.getConnection(DriverManager.java:582) >>> at java.sql.DriverManager.getConnection(DriverManager.java:185) >>> at >>> org.apache.sqoop.manager.SqlManager.makeConnection(SqlManager.java:686) >>> at >>> org.apache.sqoop.manager.GenericJdbcManager.getConnection(GenericJdbcManager.java:52) >>> at >>> org.apache.sqoop.manager.SqlManager.execute(SqlManager.java:473) >>> at >>> org.apache.sqoop.manager.SqlManager.execute(SqlManager.java:496) >>> at >>> org.apache.sqoop.manager.SqlManager.getColumnTypesForRawQuery(SqlManager.java:194) >>> at >>> org.apache.sqoop.manager.SqlManager.getColumnTypes(SqlManager.java:178) >>> at >>> org.apache.sqoop.manager.ConnManager.getColumnTypes(ConnManager.java:114) >>> at >>> org.apache.sqoop.orm.ClassWriter.getColumnTypes(ClassWriter.java:1235) >>> at >>> org.apache.sqoop.orm.ClassWriter.generate(ClassWriter.java:1060) >>> at >>> org.apache.sqoop.tool.CodeGenTool.generateORM(CodeGenTool.java:82) >>> at >>> org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:367) >>> at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:453) >>> at org.apache.sqoop.Sqoop.run(Sqoop.java:145) >>> at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65) >>> at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:181) >>> at org.apache.sqoop.Sqoop.runTool(Sqoop.java:220) >>> at org.apache.sqoop.Sqoop.runTool(Sqoop.java:229) >>> at org.apache.sqoop.Sqoop.main(Sqoop.java:238) >>> at com.cloudera.sqoop.Sqoop.main(Sqoop.java:57) >>> Caused by: java.net.ConnectException: Connection refused >>> at java.net.PlainSocketImpl.socketConnect(Native Method) >>> at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351) >>> at >>> java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213) >>> at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200) >>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366) >>> at java.net.Socket.connect(Socket.java:529) >>> at java.net.Socket.connect(Socket.java:478) >>> at java.net.Socket.<init>(Socket.java:375) >>> at java.net.Socket.<init>(Socket.java:218) >>> at >>> com.mysql.jdbc.StandardSocketFactory.connect(StandardSocketFactory.java:257) >>> at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:298) >>> ... 33 more >>> 12/07/16 17:22:30 ERROR manager.CatalogQueryManager: Failed to list >>> columns >>> 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. >>> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native >>> Method) >>> at >>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) >>> at >>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) >>> at >>> java.lang.reflect.Constructor.newInstance(Constructor.java:513) >>> at com.mysql.jdbc.Util.handleNewInstance(Util.java:411) >>> at >>> com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1116) >>> at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:348) >>> at >>> com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2391) >>> at >>> com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2428) >>> at >>> com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2213) >>> at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:797) >>> at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:47) >>> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native >>> Method) >>> at >>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) >>> at >>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) >>> at >>> java.lang.reflect.Constructor.newInstance(Constructor.java:513) >>> at com.mysql.jdbc.Util.handleNewInstance(Util.java:411) >>> at >>> com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:389) >>> at >>> com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:305) >>> at java.sql.DriverManager.getConnection(DriverManager.java:582) >>> at java.sql.DriverManager.getConnection(DriverManager.java:185) >>> at >>> org.apache.sqoop.manager.SqlManager.makeConnection(SqlManager.java:686) >>> at >>> org.apache.sqoop.manager.GenericJdbcManager.getConnection(GenericJdbcManager.java:52) >>> at >>> org.apache.sqoop.manager.CatalogQueryManager.getColumnNames(CatalogQueryManager.java:146) >>> at >>> org.apache.sqoop.orm.ClassWriter.getColumnNames(ClassWriter.java:1207) >>> at >>> org.apache.sqoop.orm.ClassWriter.generate(ClassWriter.java:1062) >>> at >>> org.apache.sqoop.tool.CodeGenTool.generateORM(CodeGenTool.java:82) >>> at >>> org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:367) >>> at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:453) >>> at org.apache.sqoop.Sqoop.run(Sqoop.java:145) >>> at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65) >>> at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:181) >>> at org.apache.sqoop.Sqoop.runTool(Sqoop.java:220) >>> at org.apache.sqoop.Sqoop.runTool(Sqoop.java:229) >>> at org.apache.sqoop.Sqoop.main(Sqoop.java:238) >>> at com.cloudera.sqoop.Sqoop.main(Sqoop.java:57) >>> Caused by: java.net.ConnectException: Connection refused >>> at java.net.PlainSocketImpl.socketConnect(Native Method) >>> at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351) >>> at >>> java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213) >>> at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200) >>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366) >>> at java.net.Socket.connect(Socket.java:529) >>> at java.net.Socket.connect(Socket.java:478) >>> at java.net.Socket.<init>(Socket.java:375) >>> at java.net.Socket.<init>(Socket.java:218) >>> at >>> com.mysql.jdbc.StandardSocketFactory.connect(StandardSocketFactory.java:257) >>> at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:298) >>> ... 29 more >>> 12/07/16 17:22:30 ERROR sqoop.Sqoop: Got exception running Sqoop: >>> java.lang.RuntimeException: >>> 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. >>> java.lang.RuntimeException: >>> 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. >>> at >>> org.apache.sqoop.manager.CatalogQueryManager.getColumnNames(CatalogQueryManager.java:162) >>> at >>> org.apache.sqoop.orm.ClassWriter.getColumnNames(ClassWriter.java:1207) >>> at >>> org.apache.sqoop.orm.ClassWriter.generate(ClassWriter.java:1062) >>> at >>> org.apache.sqoop.tool.CodeGenTool.generateORM(CodeGenTool.java:82) >>> at >>> org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:367) >>> at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:453) >>> at org.apache.sqoop.Sqoop.run(Sqoop.java:145) >>> at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65) >>> at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:181) >>> at org.apache.sqoop.Sqoop.runTool(Sqoop.java:220) >>> at org.apache.sqoop.Sqoop.runTool(Sqoop.java:229) >>> at org.apache.sqoop.Sqoop.main(Sqoop.java:238) >>> at com.cloudera.sqoop.Sqoop.main(Sqoop.java:57) >>> Caused by: 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. >>> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native >>> Method) >>> at >>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) >>> at >>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) >>> at >>> java.lang.reflect.Constructor.newInstance(Constructor.java:513) >>> at com.mysql.jdbc.Util.handleNewInstance(Util.java:411) >>> at >>> com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1116) >>> at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:348) >>> at >>> com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2391) >>> at >>> com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2428) >>> at >>> com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2213) >>> at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:797) >>> at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:47) >>> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native >>> Method) >>> at >>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) >>> at >>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) >>> at >>> java.lang.reflect.Constructor.newInstance(Constructor.java:513) >>> at com.mysql.jdbc.Util.handleNewInstance(Util.java:411) >>> at >>> com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:389) >>> at >>> com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:305) >>> at java.sql.DriverManager.getConnection(DriverManager.java:582) >>> at java.sql.DriverManager.getConnection(DriverManager.java:185) >>> at >>> org.apache.sqoop.manager.SqlManager.makeConnection(SqlManager.java:686) >>> at >>> org.apache.sqoop.manager.GenericJdbcManager.getConnection(GenericJdbcManager.java:52) >>> at >>> org.apache.sqoop.manager.CatalogQueryManager.getColumnNames(CatalogQueryManager.java:146) >>> ... 12 more >>> Caused by: java.net.ConnectException: Connection refused >>> at java.net.PlainSocketImpl.socketConnect(Native Method) >>> at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351) >>> at >>> java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213) >>> at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200) >>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366) >>> at java.net.Socket.connect(Socket.java:529) >>> at java.net.Socket.connect(Socket.java:478) >>> at java.net.Socket.<init>(Socket.java:375) >>> at java.net.Socket.<init>(Socket.java:218) >>> at >>> com.mysql.jdbc.StandardSocketFactory.connect(StandardSocketFactory.java:257) >>> at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:298) >>> ... 29 more >>> >>> >>> >>> >>> Please suggest and help me on this issue. >>> >>> Thanks, >>> Prabhu. >>> >> >> >
