Hi Indika, Everything runs fine even for a concurrency level of 100. Sorry for the false alarm.
I'm faced with a limitation on my side to increase the load further, but this should be more than fine for the sample code I'm developing. On Tue, Apr 19, 2011 at 5:44 PM, Tharindu Mathew <[email protected]> wrote: > After further testing I realized that this timeout occurs when I do a read > that returns a large number of rows (> 2000). > > If I do write only this problem doesn't come up. So, I think it's not > recommended to do a read that returns such a large number of rows. I was > doing it for testing purposes to check the number of rows after each write, > so it does not affect the code. > > > On Tue, Apr 19, 2011 at 5:06 PM, Indika Kumara <[email protected]> wrote: > >> Seems like the processing at the server is slow. I am yet to run a perf >> test. I will run a perf test and fix the issue. Tharindu, could I get the >> same test setup you are using? I will meet you tomorrow off-line. >> >> Thanks, >> >> Indika >> >> On Tue, Apr 19, 2011 at 5:32 PM, Tharindu Mathew <[email protected]>wrote: >> >>> I'm currently load testing a piece of code using the cassandra client >>> component. I'm using a Cassandra server running separately. >>> >>> It seems that the error is coming from the client side. My load test is >>> done with level of concurrency = 50. >>> >>> The stack trace is given below: >>> >>> [2011-04-19 15:06:16,008] INFO >>> {me.prettyprint.cassandra.hector.TimingLogger} - start[1303205660385] >>> time[115623] tag[READ.fail_] >>> [2011-04-19 15:06:15,998] INFO >>> {me.prettyprint.cassandra.connection.CassandraHostRetryService} - Downed >>> Host retry shutdown complete >>> [2011-04-19 15:06:15,997] ERROR >>> {me.prettyprint.cassandra.connection.HConnectionManager} - Exception: >>> me.prettyprint.hector.api.exceptions.HTimedOutException: >>> TimedOutException() >>> at >>> me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:32) >>> at >>> me.prettyprint.cassandra.service.KeyspaceServiceImpl$4.execute(KeyspaceServiceImpl.java:194) >>> at >>> me.prettyprint.cassandra.service.KeyspaceServiceImpl$4.execute(KeyspaceServiceImpl.java:176) >>> at >>> me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation.java:101) >>> at >>> me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:155) >>> at >>> me.prettyprint.cassandra.service.KeyspaceServiceImpl.operateWithFailover(KeyspaceServiceImpl.java:129) >>> at >>> me.prettyprint.cassandra.service.KeyspaceServiceImpl.getSuperRangeSlices(KeyspaceServiceImpl.java:198) >>> at >>> me.prettyprint.cassandra.model.thrift.ThriftRangeSuperSlicesQuery$1.doInKeyspace(ThriftRangeSuperSlicesQuery.java:71) >>> at >>> me.prettyprint.cassandra.model.thrift.ThriftRangeSuperSlicesQuery$1.doInKeyspace(ThriftRangeSuperSlicesQuery.java:67) >>> at >>> me.prettyprint.cassandra.model.KeyspaceOperationCallback.doInKeyspaceAndMeasure(KeyspaceOperationCallback.java:20) >>> at >>> me.prettyprint.cassandra.model.ExecutingKeyspace.doExecute(ExecutingKeyspace.java:72) >>> at >>> me.prettyprint.cassandra.model.thrift.ThriftRangeSuperSlicesQuery.execute(ThriftRangeSuperSlicesQuery.java:66) >>> at >>> org.wso2.carbon.bam.receiver.persistence.NoSQLDataStore.persistEvent(NoSQLDataStore.java:135) >>> at >>> org.wso2.carbon.bam.receiver.internal.QueueWorker.run(QueueWorker.java:78) >>> at >>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441) >>> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) >>> at java.util.concurrent.FutureTask.run(FutureTask.java:138) >>> at >>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) >>> at >>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) >>> at java.lang.Thread.run(Thread.java:619) >>> Caused by: TimedOutException() >>> at >>> org.apache.cassandra.thrift.Cassandra$get_range_slices_result.read(Cassandra.java:12104) >>> at >>> org.apache.cassandra.thrift.Cassandra$Client.recv_get_range_slices(Cassandra.java:732) >>> at >>> org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cassandra.java:704) >>> at >>> me.prettyprint.cassandra.service.KeyspaceServiceImpl$4.execute(KeyspaceServiceImpl.java:182) >>> ... 18 more >>> >>> >>> >>> >>> -- >>> Regards, >>> >>> Tharindu >>> >>> >>> _______________________________________________ >>> Carbon-dev mailing list >>> [email protected] >>> http://mail.wso2.org/cgi-bin/mailman/listinfo/carbon-dev >>> >>> >> >> _______________________________________________ >> Carbon-dev mailing list >> [email protected] >> http://mail.wso2.org/cgi-bin/mailman/listinfo/carbon-dev >> >> > > > -- > Regards, > > Tharindu > > -- Regards, Tharindu
_______________________________________________ Carbon-dev mailing list [email protected] http://mail.wso2.org/cgi-bin/mailman/listinfo/carbon-dev
