Extracting table from Mysql to hive using talend

[Anonymous]

Hi,
I want to extract a table from mysql to hive using talend (big data studio)....
Can anyone guide me how to do that???

[Anonymous]

I have a table in hive.... now i want to create another table in hive using the contents of already existing table in hive.... I am trying to use insert query but not able to do it.....

my query is :
"INSERT into table
importedcustomer
(
SELECT *
FROM databasename.customer
)"


plz guide me....

[Anonymous]

Hi,
Did you use TalendHelpCenter:tHiveRow to execute your query?
Best regards
Sabrina

[Anonymous]

Hi,
My issue is resolved now..... there were some permission errors......
Thnx a lot for your guidance.....

[Anonymous]

Hi....
I am trying to join tables in mysql & create a new table with that..... but getting error in that..
attaching the image ....

Error is as follows :

Exception in component tELTMysqlOutput_1
java.sql.SQLException: Access denied for user ''@'localhost' (using password: NO)
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1074)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4096)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4028)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:919)
at com.mysql.jdbc.MysqlIO.secureAuth411(MysqlIO.java:4612)
at com.mysql.jdbc.MysqlIO.doHandshake(MysqlIO.java:1296)
at com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2412)
at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2445)
at com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2230)
at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:813)
at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:47)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:525)
at com.mysql.jdbc.Util.handleNewInstance(Util.java:411)
at com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:399)
at com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:334)
at java.sql.DriverManager.getConnection(DriverManager.java:579)
at java.sql.DriverManager.getConnection(DriverManager.java:221)
at sampleproject.tjoinsql_0_1.tjoinsql.tELTMysqlMap_1Process(tjoinsql.java:457)
at sampleproject.tjoinsql_0_1.tjoinsql.tMysqlConnection_1Process(tjoinsql.java:1399)
at sampleproject.tjoinsql_0_1.tjoinsql.runJobInTOS(tjoinsql.java:1617)
at sampleproject.tjoinsql_0_1.tjoinsql.main(tjoinsql.java:1482)
disconnected
Job tjoinsql ended at 14:59 26/05/2014.

[Anonymous]

Exception in component tELTMysqlOutput_1
java.sql.SQLException: Access denied for user ''@'localhost' (using password: NO)

The error indicates wrong username/password, check that you have configured right connection parameters on tELTMysqlMap.
Shong

[Anonymous]

All the credentials are correct... but still it is showing the error..

[Anonymous]

Can you try to create a Mysql connection with the same credentials under Metadata of Repository perspective and check the connection? To me, it is really an authentication issue.

Shong