Any one here came across a situation like this ? Thank you!
On Thursday, July 9, 2015, Ajay Chander <ajay.che...@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.che...@gmail.com
> <javascript:_e(%7B%7D,'cvml','ajay.che...@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 <ajay.che...@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
>>>
>>>
