I'm trying to write to CF created with CQL3 but I'm getting an error.
I'm using the same config I used with CLI created CF. Do I have to make any changes?
Thanks.
5981 [batch-bolt-thread] WARN com.netflix.astyanax.connectionpool.impl.Slf4jConnectionPoolMonitorImpl - BadRequestException: [host=10.126.96.210(10.126.96.210):9160, latency=16(16), attempts=1]InvalidRequestException(why:Not enough bytes to read value of component 0)
5995 [batch-bolt-thread] ERROR com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt - Unable to write batch.
com.netflix.astyanax.connectionpool.exceptions.BadRequestException: BadRequestException: [host=10.126.96.210(10.126.96.210):9160, latency=16(16), attempts=1]InvalidRequestException(why:Not enough bytes to read value of component 0)
at com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(ThriftConverter.java:159) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:61) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:28) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:151) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(AbstractExecuteWithFailoverImpl.java:69) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(AbstractHostPartitionConnectionPool.java:253) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.executeOperation(ThriftKeyspaceImpl.java:464) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.ThriftKeyspaceImpl.access$100(ThriftKeyspaceImpl.java:67) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1.execute(ThriftKeyspaceImpl.java:103) ~[astyanax-1.56.24.jar:na]
at com.hmsonline.storm.cassandra.client.AstyanaxClient.writeTuples(AstyanaxClient.java:384) ~[storm-cassandra-0.4.0-rc4-SNAPSHOT.jar:na]
at com.hmsonline.storm.cassandra.bolt.CassandraBolt.writeTuples(CassandraBolt.java:55) ~[storm-cassandra-0.4.0-rc4-SNAPSHOT.jar:na]
at com.hmsonline.storm.cassandra.bolt.CassandraBatchingBolt.executeBatch(CassandraBatchingBolt.java:33) ~[storm-cassandra-0.4.0-rc4-SNAPSHOT.jar:na]
at com.hmsonline.storm.cassandra.bolt.AbstractBatchingBolt$BatchThread.run(AbstractBatchingBolt.java:118) [storm-cassandra-0.4.0-rc4-SNAPSHOT.jar:na]
Caused by: org.apache.cassandra.thrift.InvalidRequestException: null
at org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20253) ~[cassandra-thrift-1.1.1.jar:1.1.1]
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) ~[libthrift-0.7.0.jar:0.7.0]
at org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:922) ~[cassandra-thrift-1.1.1.jar:1.1.1]
at org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:908) ~[cassandra-thrift-1.1.1.jar:1.1.1]
at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1$1.internalExecute(ThriftKeyspaceImpl.java:109) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1$1.internalExecute(ThriftKeyspaceImpl.java:106) ~[astyanax-1.56.24.jar:na]
at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:56) ~[astyanax-1.56.24.jar:na]
... 11 common frames omitted
I'm trying to write to CF created with CQL3 but I'm getting an error.
I'm using the same config I used with CLI created CF. Do I have to make any changes?
Thanks.