I ran BAM without sending events to it and then it don't give any exeption.
On Mon, Feb 10, 2014 at 6:53 PM, Chamila Wijayarathna <[email protected]>wrote: > 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. > > -- *Chamila Wijayarathna* Engineering Intern, WSO2 Inc.
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
