Hi Prabath,

This is the error we got while deleting messages.

[2014-10-03 12:16:55,059] ERROR
{org.wso2.andes.store.cassandra.CQLBasedMessageStoreImpl} -  Error while
deleting messages
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s)
tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:64)
    at
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException(ResultSetFuture.java:269)
    at
com.datastax.driver.core.ResultSetFuture.getUninterruptibly(ResultSetFuture.java:183)
    at com.datastax.driver.core.Session.execute(Session.java:111)
    at
org.wso2.andes.store.cassandra.dao.GenericCQLDAO.batchExecute(GenericCQLDAO.java:207)
    at
org.wso2.andes.store.cassandra.CQLBasedMessageStoreImpl.deleteMessageMetadataFromQueue(CQLBasedMessageStoreImpl.java:299)
    at
org.wso2.andes.kernel.storemanager.DurableAsyncStoringManager.deleteMessages(DurableAsyncStoringManager.java:327)
    at
org.wso2.andes.kernel.storemanager.DurableAsyncStoringManager.processAckReceived(DurableAsyncStoringManager.java:203)
    at
org.wso2.andes.kernel.distrupter.AckHandler.onEvent(AckHandler.java:30)
    at
org.wso2.andes.kernel.distrupter.AckHandler.onEvent(AckHandler.java:19)
    at
com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:113)
    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:662)
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:106)
    at
com.datastax.driver.core.RequestHandler$1.run(RequestHandler.java:177)
    ... 3 more
Oct 3, 2014 12:16:55 PM com.lmax.disruptor.FatalExceptionHandler
handleEventException
SEVERE: Exception processing: 12095
org.wso2.andes.kernel.AndesAckData@5341cc77
org.wso2.andes.kernel.AndesException:
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s)
tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
org.wso2.andes.store.cassandra.CQLBasedMessageStoreImpl.deleteMessageMetadataFromQueue(CQLBasedMessageStoreImpl.java:303)
    at
org.wso2.andes.kernel.storemanager.DurableAsyncStoringManager.deleteMessages(DurableAsyncStoringManager.java:327)
    at
org.wso2.andes.kernel.storemanager.DurableAsyncStoringManager.processAckReceived(DurableAsyncStoringManager.java:203)
    at
org.wso2.andes.kernel.distrupter.AckHandler.onEvent(AckHandler.java:30)
    at
org.wso2.andes.kernel.distrupter.AckHandler.onEvent(AckHandler.java:19)
    at
com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:113)
    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:662)
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:64)
    at
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException(ResultSetFuture.java:269)
    at
com.datastax.driver.core.ResultSetFuture.getUninterruptibly(ResultSetFuture.java:183)
    at com.datastax.driver.core.Session.execute(Session.java:111)
    at
org.wso2.andes.store.cassandra.dao.GenericCQLDAO.batchExecute(GenericCQLDAO.java:207)
    at
org.wso2.andes.store.cassandra.CQLBasedMessageStoreImpl.deleteMessageMetadataFromQueue(CQLBasedMessageStoreImpl.java:299)
    ... 8 more
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:106)
    at
com.datastax.driver.core.RequestHandler$1.run(RequestHandler.java:177)
    ... 3 more
Exception in thread "pool-25-thread-1" java.lang.RuntimeException:
org.wso2.andes.kernel.AndesException:
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s)
tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
com.lmax.disruptor.FatalExceptionHandler.handleEventException(FatalExceptionHandler.java:45)
    at
com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
    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:662)
Caused by: org.wso2.andes.kernel.AndesException:
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s)
tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
org.wso2.andes.store.cassandra.CQLBasedMessageStoreImpl.deleteMessageMetadataFromQueue(CQLBasedMessageStoreImpl.java:303)
    at
org.wso2.andes.kernel.storemanager.DurableAsyncStoringManager.deleteMessages(DurableAsyncStoringManager.java:327)
    at
org.wso2.andes.kernel.storemanager.DurableAsyncStoringManager.processAckReceived(DurableAsyncStoringManager.java:203)
    at
org.wso2.andes.kernel.distrupter.AckHandler.onEvent(AckHandler.java:30)
    at
org.wso2.andes.kernel.distrupter.AckHandler.onEvent(AckHandler.java:19)
    at
com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:113)
    ... 3 more
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:64)
    at
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException(ResultSetFuture.java:269)
    at
com.datastax.driver.core.ResultSetFuture.getUninterruptibly(ResultSetFuture.java:183)
    at com.datastax.driver.core.Session.execute(Session.java:111)
    at
org.wso2.andes.store.cassandra.dao.GenericCQLDAO.batchExecute(GenericCQLDAO.java:207)
    at
org.wso2.andes.store.cassandra.CQLBasedMessageStoreImpl.deleteMessageMetadataFromQueue(CQLBasedMessageStoreImpl.java:299)
    ... 8 more
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (tried: /127.0.0.1 (Timeout during read))
    at
com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:106)
    at
com.datastax.driver.core.RequestHandler$1.run(RequestHandler.java:177)
    ... 3 more


We tried this scenario increasing the number of threads in thread pool to
1000, but same error occurred.

Thank you,
Sajini.


On Wed, Oct 1, 2014 at 5:22 PM, Sajini De Silva <[email protected]> wrote:

> Hi,
>
> I'm getting following exception in MB when doing load testing.
>
> SEVERE: Exception processing: 81
> org.wso2.andes.kernel.distrupter.CassandraDataEvent@2d524d15
> com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s)
> tried for query failed (tried: /127.0.0.1 (Timeout during read))
>     at
> com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:64)
>     at
> com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException(ResultSetFuture.java:269)
>     at
> com.datastax.driver.core.ResultSetFuture.getUninterruptibly(ResultSetFuture.java:183)
>     at com.datastax.driver.core.Session.execute(Session.java:111)
>     at
> org.wso2.andes.store.cassandra.dao.GenericCQLDAO.batchExecute(GenericCQLDAO.java:207)
>     at
> org.wso2.andes.store.cassandra.CQLBasedMessageStoreImpl.storeMessagePart(CQLBasedMessageStoreImpl.java:121)
>     at
> org.wso2.andes.kernel.distrupter.AlternatingCassandraWriter.onEvent(AlternatingCassandraWriter.java:81)
>     at
> org.wso2.andes.kernel.distrupter.AlternatingCassandraWriter.onEvent(AlternatingCassandraWriter.java:38)
>     at
> com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:113)
>     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:662)
>
> Does anyone knows the cause for this error?
>
> --
> Sajini De SIlva
> Software Engineer; WSO2 Inc.; http://wso2.com ,
> Email: [email protected]
> Blog: http://sajinid.blogspot.com/
> Git hub profile: https://github.com/sajinidesilva
>
> Phone: +94 712797729
>
>


-- 
Sajini De SIlva
Software Engineer; WSO2 Inc.; http://wso2.com ,
Email: [email protected]
Blog: http://sajinid.blogspot.com/
Git hub profile: https://github.com/sajinidesilva

Phone: +94 712797729
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev

Reply via email to