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 <[email protected]> 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 <[email protected]
> <javascript:_e(%7B%7D,'cvml','[email protected]');>> 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
>>
>>
