Getting error while using tCassandraOutputbulkExec

Four Stars

Getting error while using tCassandraOutputbulkExec

when i am using tCassandraOutputbulkExec it gives me following error: 
Starting job incremental_job at 12:09 14/04/2015.
connecting to socket on port 3390
connected
connecting to socket on port 4478
connected
: org.apache.cassandra.cql3.QueryProcessor - Unable to initialize MemoryMeter (jamm not specified as javaagent).  This means Cassandra will be unable to measure object sizes accurately and may consequently OOM.
: org.apache.cassandra.config.YamlConfigurationLoader - Loading settings from jar:file:/E:/TOS_BD-20141207_1530-V5.6.1/workspace/.Java/lib/cassandra-2-0-8-conf.jar!/cassandra.yaml
: org.apache.cassandra.config.DatabaseDescriptor - Data files directories:
: org.apache.cassandra.config.DatabaseDescriptor - Commit log directory: /var/lib/cassandra/commitlog
: org.apache.cassandra.config.DatabaseDescriptor - DiskAccessMode 'auto' determined to be mmap, indexAccessMode is mmap
: org.apache.cassandra.config.DatabaseDescriptor - disk_failure_policy is stop
: org.apache.cassandra.config.DatabaseDescriptor - commit_failure_policy is stop
: org.apache.cassandra.config.DatabaseDescriptor - Global memtable threshold is enabled at 227MB
: org.apache.cassandra.config.DatabaseDescriptor - Not using multi-threaded compaction
: org.apache.cassandra.utils.CLibrary - JNA not found. Native methods will be disabled.
Established connection to initial hosts
Opening sstables and calculating sections to stream
: org.apache.cassandra.io.sstable.SSTableReader - Opening C:\Users\saurabh.shukla\Desktop\ssttab\demo\users1\demo-users1-jb-1 (272 bytes)
Streaming relevant part of C:\Users\saurabh.shukla\Desktop\ssttab\demo\users1\demo-users1-jb-1-Data.db to
: org.apache.cassandra.streaming.StreamResultFuture - Executing streaming plan for Bulk Load
: org.apache.cassandra.streaming.StreamResultFuture - Beginning stream session with /127.0.0.1
Streaming session ID: fa667270-e270-11e4-8b6c-83765da0664d
: org.apache.cassandra.streaming.StreamResultFuture - Prepare completed. Receiving 0 files(0 bytes), sending 1 files(272 bytes)

progress:
progress:
progress:
progress: : org.apache.cassandra.streaming.StreamResultFuture - Session with /127.0.0.1 is complete
Streaming to the following hosts failed:

java.util.concurrent.ExecutionException: org.apache.cassandra.streaming.StreamException: Stream failed
: org.apache.cassandra.streaming.StreamResultFuture - Stream failed
Job incremental_job ended at 12:09 14/04/2015.
Screenshot of settings attached. Tried all possible solutions still its not working.
Would appreciate if you can help us, this will help us in proposing talend to our client.
Thanks,
Saurabh.

Moderator

Re: Getting error while using tCassandraOutputbulkExec

Hi,
It seems your screenshot is missing. Could you please check it?
Make sure that your screenshot file is not bigger than 2MB.
Screenshots works only if you drag&drop the image directly in the editor window.

Best regards
Sabrina
--
Don't forget to give kudos when a reply is helpful and click Accept the solution when you think you're good with it.
Four Stars

Re: Getting error while using tCassandraOutputbulkExec

Table definition :
CREATE TABLE users1(
firstname text,
lastname text,
age int,
email text,
city text,
PRIMARY KEY (lastname)) 
Moderator

Re: Getting error while using tCassandraOutputbulkExec

Hi,
Have you already checked component reference:TalendHelpCenter:tCassandraOutputBulkExec? Are you using JDK 1.7?
Best regards
Sabrina
--
Don't forget to give kudos when a reply is helpful and click Accept the solution when you think you're good with it.
Four Stars

Re: Getting error while using tCassandraOutputbulkExec

Yes Sabrina , I have checked reference for this component. Looks like this component uses SSTableSimpleUnsortedWriter without using composite types and hence doesnot support CQL3. Kindly confirm.
Employee

Re: Getting error while using tCassandraOutputbulkExec

Shukla did you check if you are using JDK 1.7 like your screen shot was stating in red? It will be a perquisite of using this component. Do a java -version inside of a terminal or cmd window and check this.
One Star

Re: Getting error while using tCassandraOutputbulkExec

My Cassandra is running in jdk 1.8 version and Talend also working in JDK 1.8 Version , so there is no possibility to run this component ...????????????? Smiley Sad
Four Stars

Re: Getting error while using tCassandraOutputbulkExec

Hi eteitelbaum ,
I was using JDK 1.7 only and even tried with JDK 1.8 but problem didn't get resolved.
Thanks,
Saurabh.