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.
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.
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.
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.
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 ...?????????????