I have a two node cluster. Tried with both 2.0.4 and 2.0.5.
I have tried your code, and exactly after inserting 127 rows, the next
insert fails.
10.566482102276002 123
2.7760618708015863 124
8.936212688296054 125
9.532923906962095 126
7.5081516753554505 127
java.lang.RuntimeException: failed to write data to C*
at demo.AstClient.insert(AstClient.java:75)
at demo.AstClient.loadData(AstClient.java:112)
at demo.AstClient.main(AstClient.java:127)
Caused by:
com.netflix.astyanax.connectionpool.exceptions.BadRequestException:
BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=22(22),
attempts=1]InvalidRequestException(why:String didn't validate.)
at
com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(ThriftConverter.java:159)
at
com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:61)
at
com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:28)
at
com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:151)
at
com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(AbstractExecuteWithFailoverImpl.java:69)
at
com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(AbstractHostPartitionConnectionPool.java:256)
at
com.netflix.astyanax.thrift.ThriftKeyspaceImpl.executeOperation(ThriftKeyspaceImpl.java:478)
at
com.netflix.astyanax.thrift.ThriftKeyspaceImpl.access$000(ThriftKeyspaceImpl.java:73)
at
com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1.execute(ThriftKeyspaceImpl.java:116)
at demo.AstClient.insert(AstClient.java:72)
... 2 more
Caused by: InvalidRequestException(why:String didn't validate.)
at
org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20833)
at
org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:964)
at
org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:950)
at
com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1$1.internalExecute(ThriftKeyspaceImpl.java:122)
at
com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1$1.internalExecute(ThriftKeyspaceImpl.java:119)
at
com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:56)
... 10 more
On Wed, Feb 19, 2014 at 12:38 PM, Rüdiger Klaehn <[email protected]> wrote:
> On Wed, Feb 19, 2014 at 7:49 PM, Sylvain Lebresne <[email protected]>wrote:
>
>> On Wed, Feb 19, 2014 at 11:27 AM, Rüdiger Klaehn <[email protected]>wrote:
>>
>>>
>>> Am I doing something wrong, or is this a fundamental limitation of CQL.
>>>
>>
>> Neither. I believe you are running into
>> https://issues.apache.org/jira/browse/CASSANDRA-6737, which is a bug, a
>> performance bug, which we should and will fix. So thanks for the report. If
>> you could give a shot to the patch on that issue and check if it helps,
>> that would definitively be much appreciated.
>>
>> Hi Sylvain,
>
> Yes, this issue looks almost identical to the problem I have been
> experiencing. Great to hear that you are aware of the issue and that there
> is a fix.
>
> I have cloned the cassandra repo, applied the patch, and built it. But
> when I want to run the bechmark I get an exception. See below. I tried with
> a non-managed dependency to
> cassandra-driver-core-2.0.0-rc3-SNAPSHOT-jar-with-dependencies.jar, which I
> compiled from source because I read that that might help. But that did not
> make a difference.
>
> So currently I don't know how to give the patch a try. Any ideas?
>
> cheers,
>
> Rüdiger
>
> Exception in thread "main" java.lang.IllegalArgumentException:
> replicate_on_write is not a column defined in this metadata
> at
> com.datastax.driver.core.ColumnDefinitions.getAllIdx(ColumnDefinitions.java:273)
> at
> com.datastax.driver.core.ColumnDefinitions.getFirstIdx(ColumnDefinitions.java:279)
> at com.datastax.driver.core.Row.getBool(Row.java:117)
> at
> com.datastax.driver.core.TableMetadata$Options.<init>(TableMetadata.java:474)
> at com.datastax.driver.core.TableMetadata.build(TableMetadata.java:107)
> at
> com.datastax.driver.core.Metadata.buildTableMetadata(Metadata.java:128)
> at com.datastax.driver.core.Metadata.rebuildSchema(Metadata.java:89)
> at
> com.datastax.driver.core.ControlConnection.refreshSchema(ControlConnection.java:259)
> at
> com.datastax.driver.core.ControlConnection.tryConnect(ControlConnection.java:214)
> at
> com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:161)
> at
> com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:77)
> at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:890)
> at
> com.datastax.driver.core.Cluster$Manager.newSession(Cluster.java:910)
> at
> com.datastax.driver.core.Cluster$Manager.access$200(Cluster.java:806)
> at com.datastax.driver.core.Cluster.connect(Cluster.java:158)
> at
> cassandra.CassandraTestMinimized$delayedInit$body.apply(CassandraTestMinimized.scala:31)
> at scala.Function0$class.apply$mcV$sp(Function0.scala:40)
> at
> scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
> at scala.App$$anonfun$main$1.apply(App.scala:71)
> at scala.App$$anonfun$main$1.apply(App.scala:71)
> at scala.collection.immutable.List.foreach(List.scala:318)
> at
> scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:32)
> at scala.App$class.main(App.scala:71)
> at
> cassandra.CassandraTestMinimized$.main(CassandraTestMinimized.scala:5)
> at cassandra.CassandraTestMinimized.main(CassandraTestMinimized.scala)
>
>
>> There is absolutely no fundamental reason why a CQL operation would be
>> more than 10 times slower than it's thrift equivalent, such dramatic
>> difference is indicative of a bug, something obviously wrong.
>>
>> --
>> Sylvain
>>
>
>
