You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@sqoop.apache.org by prabhu k <pr...@gmail.com> on 2012/07/16 14:21:20 UTC
import msql to hive
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.
Re: import msql to hive
Posted by prabhu k <pr...@gmail.com>.
it's working now. Thanks for all helping this issue.
On Fri, Jul 20, 2012 at 1:46 PM, ablozhou@gmail.com <ab...@gmail.com>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 <ra...@gmail.com>
>
>> 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 <pr...@gmail.com> 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.
>>>
>>
>>
>
RE: import msql to hive
Posted by yo...@wipro.com.
Hi prabhu,
Have you set HBASE_HOME and HIVE_HOME on the terminal from where you are running SQOOP. and check the correct port for MySql.
Regards
Yogesh Kumar Dhari
________________________________
From: ablozhou@gmail.com [ablozhou@gmail.com]
Sent: Friday, July 20, 2012 1:46 PM
To: user@sqoop.apache.org
Subject: Re: import msql to hive
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>, 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 <ra...@gmail.com>>
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 <pr...@gmail.com>> 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<http://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<http://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.
Please do not print this email unless it is absolutely necessary.
The information contained in this electronic message and any attachments to this message are intended for the exclusive use of the addressee(s) and may contain proprietary, confidential or privileged information. If you are not the intended recipient, you should not disseminate, distribute or copy this e-mail. Please notify the sender immediately and destroy all copies of this message and any attachments.
WARNING: Computer viruses can be transmitted via email. The recipient should check this email and any attachments for the presence of viruses. The company accepts no liability for any damage caused by any virus transmitted by this email.
www.wipro.com
Re: import msql to hive
Posted by "ablozhou@gmail.com" <ab...@gmail.com>.
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 <ra...@gmail.com>
> 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 <pr...@gmail.com> 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.
>>
>
>
Re: import msql to hive
Posted by Rajesh Koilpillai <ra...@gmail.com>.
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 <pr...@gmail.com> 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.
>