How to use CqlBulkOutputFormat with MultipleOutputs

2015-02-11 Thread Aby Kuruvilla
Have been trying to import data into multiple Column Families through a Hadoop job. Was able to use CqlOutputFormat to move data to a single column family, but don't think this supports imports to multiple column families. From some searching saw that CqlBulkOutputformat has support to write to mu

Streaming failures during bulkloading data using CqlBulkOutputFormat

2015-03-04 Thread Aby Kuruvilla
I am trying to use the CqlBulkOutputFormat in a Hadoop job to bulk load data into Cassandra. Was not able to find any documentation of this new output format , but from looking through the code this uses CQLSSTableWriter to write SSTable files to disk , which are then streamed to Cassandra using S

Re: Streaming failures during bulkloading data using CqlBulkOutputFormat

2015-03-05 Thread Aby Kuruvilla
failed On Wed, Mar 4, 2015 at 1:18 PM, Yuki Morishita wrote: > Do you have corresponding error in the other side of the stream > (/192.168.56.11)? > > > On Wed, Mar 4, 2015 at 9:11 AM, Aby Kuruvilla > wrote: > > I am trying to use the CqlBulkOutputFormat in a Hadoop

Re: Streaming failures during bulkloading data using CqlBulkOutputFormat

2015-03-05 Thread Aby Kuruvilla
, Mar 5, 2015 at 7:56 AM, Aby Kuruvilla > wrote: > > Hi Yuki > > > > Thanks for the reply! > > > > Here is the log from Cassandra server for the stream failure > > > > INFO [STREAM-INIT-/192.168.56.1:58578] 2015-03-04 09:20:23,816 > > StreamRe