Hello all,
I have a BAM instance running on a remote server with port offset of 1.
I'm sending a stream of wso2 events to it using an external publisher[1].
After about 1.5 hours, I am getting the following error.
*[2014-02-10 18:12:08,721] ERROR
{org.wso2.carbon.databridge.datasink.cassandra.subscriber.BAMEventSubscriber}
- Error processing event. *
*me.prettyprint.hector.api.exceptions.HTimedOutException:
TimedOutException()*
* at
me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:35)*
* at
me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:264)*
* at
me.prettyprint.cassandra.model.ExecutingKeyspace.doExecuteOperation(ExecutingKeyspace.java:97)*
* at
me.prettyprint.cassandra.model.MutatorImpl.execute(MutatorImpl.java:243)*
* at
org.wso2.carbon.databridge.persistence.cassandra.datastore.CassandraConnector.commit(CassandraConnector.java:185)*
* at
org.wso2.carbon.databridge.persistence.cassandra.datastore.CassandraConnector.insertEventList(CassandraConnector.java:676)*
* at
org.wso2.carbon.databridge.datasink.cassandra.subscriber.BAMEventSubscriber.receive(BAMEventSubscriber.java:75)*
* at
org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:80)*
* at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)*
* at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)*
* at java.util.concurrent.FutureTask.run(FutureTask.java:166)*
* at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)*
* at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)*
* at java.lang.Thread.run(Thread.java:679)*
*Caused by: TimedOutException()*
* at
org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20269)*
* at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)*
* at
org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:922)*
* at
org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:908)*
* at
me.prettyprint.cassandra.model.MutatorImpl$3.execute(MutatorImpl.java:246)*
* at
me.prettyprint.cassandra.model.MutatorImpl$3.execute(MutatorImpl.java:243)*
* at
me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation.java:103)*
* at
me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:258)*
* ... 12 more*
Full command line output can be found at [2]. Events I am sending has been
written to cassandra properly. I have a hive script which run at each
minute on BAM too.
What is the reason for this error? How can I solve it?
1. https://gist.github.com/cdwijayarathna/8915500
2. https://gist.github.com/cdwijayarathna/8915782
Thank You!
--
*Chamila Wijayarathna*
Engineering Intern,
WSO2 Inc.
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
