Do not input private or sensitive data. View Qlik Privacy & Cookie Policy.
Skip to main content

Announcements
Qlik Open Lakehouse is Now Generally Available! Discover the key highlights and partner resources here.
cancel
Showing results for 
Search instead for 
Did you mean: 
Anonymous
Not applicable

Cassandraoutput error in Talend 6.0.0RC1

Hi ,
I am trying to insert some sample data into cassandra using tcassandraoutput using settings Datastax API. But i am getting below error:
Starting job testjob at 11:53 29/06/2015.
connecting to socket on port 3487
connected
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Exception in component tCassandraOutput_1
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /192.168.189.133:9160 (com.datastax.driver.core.ConnectionException: Unexpected error during transport initialization (com.datastax.driver.core.TransportException: Channel has been closed)))
at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:223)
at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:78)
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1230)
at com.datastax.driver.core.Cluster.init(Cluster.java:157)
at com.datastax.driver.core.Cluster.connect(Cluster.java:245)
at com.datastax.driver.core.Cluster.connect(Cluster.java:278)
at wk_poc.testjob_0_1.testjob.tFileInputDelimited_1Process(testjob.java:591)
at wk_poc.testjob_0_1.testjob.runJobInTOS(testjob.java:1086)
at wk_poc.testjob_0_1.testjob.main(testjob.java:943)
disconnected
Job testjob ended at 11:53 29/06/2015.
Also i tried installing the additional package i am getting following error:
The Download failed for the following jars [db2jcc.jar, db2jcc_license_cisuz.jar, sas.core.jar, maprfs-jni-0.20.2-2.1.2.jar, nzjdbc.jar, sas.security.sspi.jar, maprfs-0.20.2-2.1.2.jar, sapjco3.jar, db2jcc_license_cu.jar, jts-1.12.jar, maprfs-0.1.ja
Please help , we need to see if talend's latest version supports datastax or not.
Thanks,
Saurabh
0683p000009MDie.png
Labels (4)
8 Replies
Anonymous
Not applicable
Author

Hi,
Does this issue repro on released version Talend Open Studio for Big Data 5.6.2?
Can you install required jar by manual to see if it works on Talend 6.0.0RC1?
Please take a look at documents about: https://help.talend.com/search/all?query=Identify+required+external+modules&content-lang=en and 
https://help.talend.com/search/all?query=Install+external+modules&content-lang=en
Best regards
Sabrina
Anonymous
Not applicable
Author

Talend started supporting datastax API in latest version i.e. 6.0.0RC1. And the modules which are not installed are not part of the component that i am using. 
Kindly Advice
Thanks.
Saurabh.
Anonymous
Not applicable
Author

hi all,
be aware that 6.0.0RC1 is a Release Candidate and not a Stable version
try&switch to a stable release
regards
laurent
Anonymous
Not applicable
Author

Hi ,
Yes we are aware about the version , but we need to know test the datastax api. That's the reason we were testing it on 6.0.0RC1.
Regards,
Saurabh.
Anonymous
Not applicable
Author

Hi All,
I resolved the issue by importing the required jars in the beginning of the job using tLibraryload component.I loaded the jars in the beginning of my job and it seemed to worked fine with me. Another change you need to do is change the port in Cassandraoutput component's default setting. List of jars loaded through tLibraryload component and changes made:
-- Cassandra-all-2.0.8.jar
-- Metrics-core-3.0.2.jar
-- netty-3.9.0.Final.jar
-- snappy-java-1.0.4.1.jar
-- lz4-1.2.0.jar
-- slf4j.-jdk14-1.6.1.jar
-- Changed the default port in Cassandraoutput component from 9160 to 9042 since native_transport_port: 9042
Please find attached the screenshot of the job.
Thanks,
Saurabh.
0683p000009ME6x.png
Anonymous
Not applicable
Author

Hi  shukla.saurabh,
Thanks for sharing your solution with us. It's helpful.
Best regards
Sabrina
Anonymous
Not applicable
Author

Hello,
I am trying to import data from MSSQL Server into Cassandra. First error I received was : Failed to load class "org.slf4j.impl.StaticLoggerBinder".  which lead me to this thread.
I imported the libraries in the following way:
-- Cassandra-all-2.0.8.jar -> tLibraryLoad_1 (onSubjobOk -> link to  tLibraryLoad_2 &  tLibraryLoad_3 )
-- Metrics-core-3.0.2.jar  -> tLibraryLoad_2 ( onSubjobOk -> link to  tLibraryLoad_4  )
-- netty-3.9.0.Final.jar  -> tLibraryLoad_3 ( onSubjobOk -> link to  MSSQL Connection )
-- snappy-java-1.0.4.1.jar  -> tLibraryLoad_4  ( onSubjobOk -> link to  tLibraryLoad_5 )
-- lz4-1.2.0.jar  -> tLibraryLoad_5  ( onSubjobOk -> link to  tLibraryLoad_6 )
-- slf4j.-jdk14-1.6.1.jar   -> tLibraryLoad_6  (no output links  )
and then ran the job again and got the error: 
com.datastax.driver.core.policies.DCAwareRoundRobinPolicy init INFO: Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct datacenter name with DCAwareRoundRobinPolicy constructor)
I would have to specify that this is the first time I'm using Talend and so I don't really have a lot of knowledge on it. I might have linked them wrong maybe? I'm not exactly sure on how the libraries are imported into the project.
I have attached also my job and the errors I receive. 
Thank you so much for any help in solving my issue!
Anonymous
Not applicable
Author

I saw that the attachments did not post. i'll post them here
0683p000009MDyB.png 0683p000009ME72.png