You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@cassandra.apache.org by Ajay Chander <aj...@gmail.com> on 2015/07/10 07:43:30 UTC
Re: Write into composite coulmns
Any one here came across a situation like this ? Thank you!
On Thursday, July 9, 2015, Ajay Chander <aj...@gmail.com> wrote:
> More information:
>
>
> Below is my cassandra bolt.
>
>
> public CassandraTest withCassandraBolt() {
>
> String[] rowKeyFields = {“item","location”};
>
> HashMap<String, Object> clientConfig = newHashMap<String, Object>();
>
> clientConfig.put(StormCassandraConstants.CASSANDRA_HOST,
>
> this.configuration.getCassandraBoltServer());
>
> clientConfig.put(StormCassandraConstants.CASSANDRA_KEYSPACE, Arrays
>
> .asList(new String[] {this.projectConfiguration
>
> .getCassandraBoltKeyspace() }));
>
> this.stormConfig.put(
>
> this.configuration.getCassandraBoltConfigKey(),
>
> clientConfig);
>
> cassandraBolt = new CassandraBatchingBolt<Composite, String, String>(
>
> this.configuration.getCassandraBoltConfigKey(),
>
> new CompositeRowTupleMapper(
>
> this.configuration.getCassandraBoltKeyspace(),
>
> this.configuration
>
> .getCassandraBoltColumnFamily(),
>
> rowKeyFields));
>
> cassandraBolt.setAckStrategy(AckStrategy.ACK_ON_WRITE);
>
> return this;
>
> }
>
>
>
> This is my table in Cassandra:
>
>
> CREATE TABLE store ( item text, location text, type text,
> PRIMARY KEY (dpci, location) ) WITH COMPACT STORAGE;
>
>
>
> Error I am getting is below:
>
>
> 15810 [batch-bolt-thread] WARN
> com.netflix.astyanax.connectionpool.impl.Slf4jConnectionPoolMonitorImpl -
> BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> attempts=1]InvalidRequestException(why:Not enough bytes to read value of
> component 0)
>
> 15811 [batch-bolt-thread] ERROR
> com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt - Unable to write
> batch.
>
> com.netflix.astyanax.connectionpool.exceptions.BadRequestException:
> BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> attempts=1]InvalidRequestException(why:Not enough bytes to read value of
> component 0)
>
> at com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(
> ThriftConverter.java:159) ~[astyanax-thrift-1.56.44.jar:na]
>
> at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> AbstractOperationImpl.java:65) ~[astyanax-thrift-1.56.44.jar:na]
>
> at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> AbstractOperationImpl.java:28) ~[astyanax-thrift-1.56.44.jar:na]
>
> at
> com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(
> ThriftSyncConnectionFactoryImpl.java:151)
> ~[astyanax-thrift-1.56.44.jar:na]
>
> at
> com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(
> AbstractExecuteWithFailoverImpl.java:119) ~[astyanax-core-1.56.44.jar:na]
>
> at
> com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(
> AbstractHostPartitionConnectionPool.java:338)
> ~[astyanax-core-1.56.44.jar:na]
>
> at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.executeOperation(
> ThriftKeyspaceImpl.java:493) ~[astyanax-thrift-1.56.44.jar:na]
>
> at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.access$000(
> ThriftKeyspaceImpl.java:79) ~[astyanax-thrift-1.56.44.jar:na]
>
> at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1.execute(
> ThriftKeyspaceImpl.java:123) ~[astyanax-thrift-1.56.44.jar:na]
>
> at com.hmsonline.storm.cassandra.client.AstyanaxClient.writeTuples(
> AstyanaxClient.java:417) ~[classes/:na]
>
> at com.hmsonline.storm.cassandra.bolt.CassandraBolt.writeTuples(
> CassandraBolt.java:67) ~[classes/:na]
>
> at com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt.executeBatch(
> CassandraBatchingBolt.java:49) ~[classes/:na]
>
> at com.hmsonline.storm.cassandra.bolt.AbstractBatchingBolt$BatchThread.run(
> AbstractBatchingBolt.java:134) [classes/:na]
>
> On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:_e(%7B%7D,'cvml','ajay.chevva@gmail.com');>> wrote:
>
>> Hi All,
>>
>> I am having hard time in writing data into composite columns in
>> Cassandra. Any one here used "CompositeRowTupleMapper" from
>>
>>
>> https://github.com/hmsonline/storm-cassandra/blob/master/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.java
>>
>> Is there any CompositeRowTupleMapperTest.java where I can find how it can
>> be used.
>>
>> Any help is highly appreciated.
>>
>> Thank you,
>> Ajay
>>
>>
>>
>> On Thursday, July 9, 2015, Ajay Chander <aj...@gmail.com> wrote:
>>
>>> Hi Everyone,
>>>
>>> I am using hmsonline/storm-Cassandra from git. I have a table in my
>>> Cassandra which composite keys like ..
>>>
>>> Create table testable (itemid varchar, location varchar, price varchar,
>>> type varchar, primary key(itemid, location, price )) with compact storage ;
>>>
>>> Now how do I write data into this table from my storm bolt ?
>>>
>>> Any help is highly appreciated.
>>>
>>> Thank you,
>>> Ajay
>>>
>>>
Re: Write into composite coulmns
Posted by Ajay Chander <aj...@gmail.com>.
Thank you for your reply Jack!
That's my mistake. This is the actual table
CREATE TABLE store ( item text, location text, type text,
PRIMARY KEY (item, location) ) WITH COMPACT STORAGE;
And it gives the same error to me. Have been finding a way to solve it. But
no luck so far.
Thank you,
Ajay
On Friday, July 10, 2015, Jack Krupansky <ja...@gmail.com> wrote:
> First, this is a compound primary key, not a composite [partition] key.
>
> You don't have a column definition for dpci, your partition key.
>
> Compact storage requires precisely and exactly and only one non-primary key
> column, but you have two. Maybe dpci and item were supposed to be the same.
>
> -- Jack Krupansky
>
> On Fri, Jul 10, 2015 at 1:43 AM, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>> wrote:
>
> > Any one here came across a situation like this ? Thank you!
> >
> > On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>> wrote:
> >
> > > More information:
> > >
> > >
> > > Below is my cassandra bolt.
> > >
> > >
> > > public CassandraTest withCassandraBolt() {
> > >
> > > String[] rowKeyFields = {“item","location”};
> > >
> > > HashMap<String, Object> clientConfig = newHashMap<String, Object>();
> > >
> > > clientConfig.put(StormCassandraConstants.CASSANDRA_HOST,
> > >
> > > this.configuration.getCassandraBoltServer());
> > >
> > > clientConfig.put(StormCassandraConstants.CASSANDRA_KEYSPACE, Arrays
> > >
> > > .asList(new String[] {this.projectConfiguration
> > >
> > > .getCassandraBoltKeyspace() }));
> > >
> > > this.stormConfig.put(
> > >
> > > this.configuration.getCassandraBoltConfigKey(),
> > >
> > > clientConfig);
> > >
> > > cassandraBolt = new CassandraBatchingBolt<Composite, String, String>(
> > >
> > > this.configuration.getCassandraBoltConfigKey(),
> > >
> > > new CompositeRowTupleMapper(
> > >
> > > this.configuration.getCassandraBoltKeyspace(),
> > >
> > > this.configuration
> > >
> > > .getCassandraBoltColumnFamily(),
> > >
> > > rowKeyFields));
> > >
> > > cassandraBolt.setAckStrategy(AckStrategy.ACK_ON_WRITE);
> > >
> > > return this;
> > >
> > > }
> > >
> > >
> > >
> > > This is my table in Cassandra:
> > >
> > >
> > > CREATE TABLE store ( item text, location text, type text,
> > > PRIMARY KEY (dpci, location) ) WITH COMPACT STORAGE;
> > >
> > >
> > >
> > > Error I am getting is below:
> > >
> > >
> > > 15810 [batch-bolt-thread] WARN
> > >
> com.netflix.astyanax.connectionpool.impl.Slf4jConnectionPoolMonitorImpl -
> > > BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> > > attempts=1]InvalidRequestException(why:Not enough bytes to read value
> of
> > > component 0)
> > >
> > > 15811 [batch-bolt-thread] ERROR
> > > com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt - Unable to
> > write
> > > batch.
> > >
> > > com.netflix.astyanax.connectionpool.exceptions.BadRequestException:
> > > BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> > > attempts=1]InvalidRequestException(why:Not enough bytes to read value
> of
> > > component 0)
> > >
> > > at
> com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(
> > > ThriftConverter.java:159) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> > > AbstractOperationImpl.java:65) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> > > AbstractOperationImpl.java:28) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at
> > >
> >
> com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(
> > > ThriftSyncConnectionFactoryImpl.java:151)
> > > ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at
> > >
> >
> com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(
> > > AbstractExecuteWithFailoverImpl.java:119)
> ~[astyanax-core-1.56.44.jar:na]
> > >
> > > at
> > >
> >
> com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(
> > > AbstractHostPartitionConnectionPool.java:338)
> > > ~[astyanax-core-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.executeOperation(
> > > ThriftKeyspaceImpl.java:493) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.access$000(
> > > ThriftKeyspaceImpl.java:79) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1.execute(
> > > ThriftKeyspaceImpl.java:123) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.hmsonline.storm.cassandra.client.AstyanaxClient.writeTuples(
> > > AstyanaxClient.java:417) ~[classes/:na]
> > >
> > > at com.hmsonline.storm.cassandra.bolt.CassandraBolt.writeTuples(
> > > CassandraBolt.java:67) ~[classes/:na]
> > >
> > > at
> com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt.executeBatch(
> > > CassandraBatchingBolt.java:49) ~[classes/:na]
> > >
> > > at
> > com.hmsonline.storm.cassandra.bolt.AbstractBatchingBolt$BatchThread.run(
> > > AbstractBatchingBolt.java:134) [classes/:na]
> > >
> > > On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>
> > > <javascript:_e(%7B%7D,'cvml','ajay.chevva@gmail.com <javascript:;>');>>
> wrote:
> > >
> > >> Hi All,
> > >>
> > >> I am having hard time in writing data into composite columns in
> > >> Cassandra. Any one here used "CompositeRowTupleMapper" from
> > >>
> > >>
> > >>
> >
> https://github.com/hmsonline/storm-cassandra/blob/master/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.java
> > >>
> > >> Is there any CompositeRowTupleMapperTest.java where I can find how it
> > can
> > >> be used.
> > >>
> > >> Any help is highly appreciated.
> > >>
> > >> Thank you,
> > >> Ajay
> > >>
> > >>
> > >>
> > >> On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>> wrote:
> > >>
> > >>> Hi Everyone,
> > >>>
> > >>> I am using hmsonline/storm-Cassandra from git. I have a table in my
> > >>> Cassandra which composite keys like ..
> > >>>
> > >>> Create table testable (itemid varchar, location varchar, price
> varchar,
> > >>> type varchar, primary key(itemid, location, price )) with compact
> > storage ;
> > >>>
> > >>> Now how do I write data into this table from my storm bolt ?
> > >>>
> > >>> Any help is highly appreciated.
> > >>>
> > >>> Thank you,
> > >>> Ajay
> > >>>
> > >>>
> >
>
Re: Write into composite coulmns
Posted by Ajay Chander <aj...@gmail.com>.
Thank you for your reply Jack!
That's my mistake. This is the actual table
CREATE TABLE store ( item text, location text, type text,
PRIMARY KEY (item, location) ) WITH COMPACT STORAGE;
And it gives the same error to me. Have been finding a way to solve it. But
no luck so far.
Thank you,
Ajay
On Friday, July 10, 2015, Jack Krupansky <ja...@gmail.com> wrote:
> First, this is a compound primary key, not a composite [partition] key.
>
> You don't have a column definition for dpci, your partition key.
>
> Compact storage requires precisely and exactly and only one non-primary key
> column, but you have two. Maybe dpci and item were supposed to be the same.
>
> -- Jack Krupansky
>
> On Fri, Jul 10, 2015 at 1:43 AM, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>> wrote:
>
> > Any one here came across a situation like this ? Thank you!
> >
> > On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>> wrote:
> >
> > > More information:
> > >
> > >
> > > Below is my cassandra bolt.
> > >
> > >
> > > public CassandraTest withCassandraBolt() {
> > >
> > > String[] rowKeyFields = {“item","location”};
> > >
> > > HashMap<String, Object> clientConfig = newHashMap<String, Object>();
> > >
> > > clientConfig.put(StormCassandraConstants.CASSANDRA_HOST,
> > >
> > > this.configuration.getCassandraBoltServer());
> > >
> > > clientConfig.put(StormCassandraConstants.CASSANDRA_KEYSPACE, Arrays
> > >
> > > .asList(new String[] {this.projectConfiguration
> > >
> > > .getCassandraBoltKeyspace() }));
> > >
> > > this.stormConfig.put(
> > >
> > > this.configuration.getCassandraBoltConfigKey(),
> > >
> > > clientConfig);
> > >
> > > cassandraBolt = new CassandraBatchingBolt<Composite, String, String>(
> > >
> > > this.configuration.getCassandraBoltConfigKey(),
> > >
> > > new CompositeRowTupleMapper(
> > >
> > > this.configuration.getCassandraBoltKeyspace(),
> > >
> > > this.configuration
> > >
> > > .getCassandraBoltColumnFamily(),
> > >
> > > rowKeyFields));
> > >
> > > cassandraBolt.setAckStrategy(AckStrategy.ACK_ON_WRITE);
> > >
> > > return this;
> > >
> > > }
> > >
> > >
> > >
> > > This is my table in Cassandra:
> > >
> > >
> > > CREATE TABLE store ( item text, location text, type text,
> > > PRIMARY KEY (dpci, location) ) WITH COMPACT STORAGE;
> > >
> > >
> > >
> > > Error I am getting is below:
> > >
> > >
> > > 15810 [batch-bolt-thread] WARN
> > >
> com.netflix.astyanax.connectionpool.impl.Slf4jConnectionPoolMonitorImpl -
> > > BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> > > attempts=1]InvalidRequestException(why:Not enough bytes to read value
> of
> > > component 0)
> > >
> > > 15811 [batch-bolt-thread] ERROR
> > > com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt - Unable to
> > write
> > > batch.
> > >
> > > com.netflix.astyanax.connectionpool.exceptions.BadRequestException:
> > > BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> > > attempts=1]InvalidRequestException(why:Not enough bytes to read value
> of
> > > component 0)
> > >
> > > at
> com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(
> > > ThriftConverter.java:159) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> > > AbstractOperationImpl.java:65) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> > > AbstractOperationImpl.java:28) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at
> > >
> >
> com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(
> > > ThriftSyncConnectionFactoryImpl.java:151)
> > > ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at
> > >
> >
> com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(
> > > AbstractExecuteWithFailoverImpl.java:119)
> ~[astyanax-core-1.56.44.jar:na]
> > >
> > > at
> > >
> >
> com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(
> > > AbstractHostPartitionConnectionPool.java:338)
> > > ~[astyanax-core-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.executeOperation(
> > > ThriftKeyspaceImpl.java:493) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.access$000(
> > > ThriftKeyspaceImpl.java:79) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1.execute(
> > > ThriftKeyspaceImpl.java:123) ~[astyanax-thrift-1.56.44.jar:na]
> > >
> > > at com.hmsonline.storm.cassandra.client.AstyanaxClient.writeTuples(
> > > AstyanaxClient.java:417) ~[classes/:na]
> > >
> > > at com.hmsonline.storm.cassandra.bolt.CassandraBolt.writeTuples(
> > > CassandraBolt.java:67) ~[classes/:na]
> > >
> > > at
> com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt.executeBatch(
> > > CassandraBatchingBolt.java:49) ~[classes/:na]
> > >
> > > at
> > com.hmsonline.storm.cassandra.bolt.AbstractBatchingBolt$BatchThread.run(
> > > AbstractBatchingBolt.java:134) [classes/:na]
> > >
> > > On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>
> > > <javascript:_e(%7B%7D,'cvml','ajay.chevva@gmail.com <javascript:;>');>>
> wrote:
> > >
> > >> Hi All,
> > >>
> > >> I am having hard time in writing data into composite columns in
> > >> Cassandra. Any one here used "CompositeRowTupleMapper" from
> > >>
> > >>
> > >>
> >
> https://github.com/hmsonline/storm-cassandra/blob/master/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.java
> > >>
> > >> Is there any CompositeRowTupleMapperTest.java where I can find how it
> > can
> > >> be used.
> > >>
> > >> Any help is highly appreciated.
> > >>
> > >> Thank you,
> > >> Ajay
> > >>
> > >>
> > >>
> > >> On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:;>> wrote:
> > >>
> > >>> Hi Everyone,
> > >>>
> > >>> I am using hmsonline/storm-Cassandra from git. I have a table in my
> > >>> Cassandra which composite keys like ..
> > >>>
> > >>> Create table testable (itemid varchar, location varchar, price
> varchar,
> > >>> type varchar, primary key(itemid, location, price )) with compact
> > storage ;
> > >>>
> > >>> Now how do I write data into this table from my storm bolt ?
> > >>>
> > >>> Any help is highly appreciated.
> > >>>
> > >>> Thank you,
> > >>> Ajay
> > >>>
> > >>>
> >
>
Re: Write into composite coulmns
Posted by Jack Krupansky <ja...@gmail.com>.
First, this is a compound primary key, not a composite [partition] key.
You don't have a column definition for dpci, your partition key.
Compact storage requires precisely and exactly and only one non-primary key
column, but you have two. Maybe dpci and item were supposed to be the same.
-- Jack Krupansky
On Fri, Jul 10, 2015 at 1:43 AM, Ajay Chander <aj...@gmail.com> wrote:
> Any one here came across a situation like this ? Thank you!
>
> On Thursday, July 9, 2015, Ajay Chander <aj...@gmail.com> wrote:
>
> > More information:
> >
> >
> > Below is my cassandra bolt.
> >
> >
> > public CassandraTest withCassandraBolt() {
> >
> > String[] rowKeyFields = {“item","location”};
> >
> > HashMap<String, Object> clientConfig = newHashMap<String, Object>();
> >
> > clientConfig.put(StormCassandraConstants.CASSANDRA_HOST,
> >
> > this.configuration.getCassandraBoltServer());
> >
> > clientConfig.put(StormCassandraConstants.CASSANDRA_KEYSPACE, Arrays
> >
> > .asList(new String[] {this.projectConfiguration
> >
> > .getCassandraBoltKeyspace() }));
> >
> > this.stormConfig.put(
> >
> > this.configuration.getCassandraBoltConfigKey(),
> >
> > clientConfig);
> >
> > cassandraBolt = new CassandraBatchingBolt<Composite, String, String>(
> >
> > this.configuration.getCassandraBoltConfigKey(),
> >
> > new CompositeRowTupleMapper(
> >
> > this.configuration.getCassandraBoltKeyspace(),
> >
> > this.configuration
> >
> > .getCassandraBoltColumnFamily(),
> >
> > rowKeyFields));
> >
> > cassandraBolt.setAckStrategy(AckStrategy.ACK_ON_WRITE);
> >
> > return this;
> >
> > }
> >
> >
> >
> > This is my table in Cassandra:
> >
> >
> > CREATE TABLE store ( item text, location text, type text,
> > PRIMARY KEY (dpci, location) ) WITH COMPACT STORAGE;
> >
> >
> >
> > Error I am getting is below:
> >
> >
> > 15810 [batch-bolt-thread] WARN
> > com.netflix.astyanax.connectionpool.impl.Slf4jConnectionPoolMonitorImpl -
> > BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> > attempts=1]InvalidRequestException(why:Not enough bytes to read value of
> > component 0)
> >
> > 15811 [batch-bolt-thread] ERROR
> > com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt - Unable to
> write
> > batch.
> >
> > com.netflix.astyanax.connectionpool.exceptions.BadRequestException:
> > BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=21(21),
> > attempts=1]InvalidRequestException(why:Not enough bytes to read value of
> > component 0)
> >
> > at com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(
> > ThriftConverter.java:159) ~[astyanax-thrift-1.56.44.jar:na]
> >
> > at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> > AbstractOperationImpl.java:65) ~[astyanax-thrift-1.56.44.jar:na]
> >
> > at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(
> > AbstractOperationImpl.java:28) ~[astyanax-thrift-1.56.44.jar:na]
> >
> > at
> >
> com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(
> > ThriftSyncConnectionFactoryImpl.java:151)
> > ~[astyanax-thrift-1.56.44.jar:na]
> >
> > at
> >
> com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(
> > AbstractExecuteWithFailoverImpl.java:119) ~[astyanax-core-1.56.44.jar:na]
> >
> > at
> >
> com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(
> > AbstractHostPartitionConnectionPool.java:338)
> > ~[astyanax-core-1.56.44.jar:na]
> >
> > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.executeOperation(
> > ThriftKeyspaceImpl.java:493) ~[astyanax-thrift-1.56.44.jar:na]
> >
> > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.access$000(
> > ThriftKeyspaceImpl.java:79) ~[astyanax-thrift-1.56.44.jar:na]
> >
> > at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1.execute(
> > ThriftKeyspaceImpl.java:123) ~[astyanax-thrift-1.56.44.jar:na]
> >
> > at com.hmsonline.storm.cassandra.client.AstyanaxClient.writeTuples(
> > AstyanaxClient.java:417) ~[classes/:na]
> >
> > at com.hmsonline.storm.cassandra.bolt.CassandraBolt.writeTuples(
> > CassandraBolt.java:67) ~[classes/:na]
> >
> > at com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt.executeBatch(
> > CassandraBatchingBolt.java:49) ~[classes/:na]
> >
> > at
> com.hmsonline.storm.cassandra.bolt.AbstractBatchingBolt$BatchThread.run(
> > AbstractBatchingBolt.java:134) [classes/:na]
> >
> > On Thursday, July 9, 2015, Ajay Chander <ajay.chevva@gmail.com
> > <javascript:_e(%7B%7D,'cvml','ajay.chevva@gmail.com');>> wrote:
> >
> >> Hi All,
> >>
> >> I am having hard time in writing data into composite columns in
> >> Cassandra. Any one here used "CompositeRowTupleMapper" from
> >>
> >>
> >>
> https://github.com/hmsonline/storm-cassandra/blob/master/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.java
> >>
> >> Is there any CompositeRowTupleMapperTest.java where I can find how it
> can
> >> be used.
> >>
> >> Any help is highly appreciated.
> >>
> >> Thank you,
> >> Ajay
> >>
> >>
> >>
> >> On Thursday, July 9, 2015, Ajay Chander <aj...@gmail.com> wrote:
> >>
> >>> Hi Everyone,
> >>>
> >>> I am using hmsonline/storm-Cassandra from git. I have a table in my
> >>> Cassandra which composite keys like ..
> >>>
> >>> Create table testable (itemid varchar, location varchar, price varchar,
> >>> type varchar, primary key(itemid, location, price )) with compact
> storage ;
> >>>
> >>> Now how do I write data into this table from my storm bolt ?
> >>>
> >>> Any help is highly appreciated.
> >>>
> >>> Thank you,
> >>> Ajay
> >>>
> >>>
>