Hi Gayashan, Can you meet me Now.. We'll debug and see what went wrong..
Thanks, Mohan On Wed, Jun 18, 2014 at 12:06 PM, Gayashan Amarasinghe <[email protected]> wrote: > Hi all, > > I've been using the CEP to do some time batch processing with a query > similar to this, > > from in_stream#window.timeBatch(5 min) > select var1, avg(var2) as avg, count(*) as frequency > group by var1 having frequency > 2 > insert into out_stream; > > And then log the contents of the out stream using an Event formatter. > > It works as expected most of the time, however every now and then i keep > getting the following error. Any idea why I'm getting this error? > > TID: [0] [CEP] [2014-06-17 23:18:48,706] ERROR > {org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction} > - Error while dispatching events > java.lang.NullPointerException > at > org.wso2.carbon.event.stream.manager.core.internal.stream.EventJunction.sendEvents(EventJunction.java:225) > at > org.wso2.carbon.event.processor.core.internal.listener.SiddhiOutputStreamListener.receive(SiddhiOutputStreamListener.java:78) > at > org.wso2.siddhi.core.stream.output.StreamCallback.send(StreamCallback.java:83) > at > org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:56) > at > org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45) > at > org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:35) > at > org.wso2.siddhi.core.query.output.ratelimit.OutputRateManager.sendToCallBacks(OutputRateManager.java:38) > at > org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateManager.send(PassThroughOutputRateManager.java:26) > at > org.wso2.siddhi.core.query.selector.QuerySelector.sendEvents(QuerySelector.java:340) > at > org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:301) > at > org.wso2.siddhi.core.query.processor.window.TimeBatchWindowProcessor.run(TimeBatchWindowProcessor.java:113) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) > at java.util.concurrent.FutureTask.run(FutureTask.java:262) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > > Any help is much appreciated. > > Thanks. > > /Gayashan > > > -- > Gayashan Amarasinghe > Software Engineer > WSO2, Inc. ; http://wso2.com > lean. enterprise. middleware > > Mobile: +94718314517 > Blog: gayashan-a.blogspot.com > > _______________________________________________ > Dev mailing list > [email protected] > http://wso2.org/cgi-bin/mailman/listinfo/dev > > -- *V. Mohanadarshan* *Software Engineer,* *Data Technologies Team,* *WSO2, Inc. http://wso2.com <http://wso2.com> * *lean.enterprise.middleware.* email: [email protected] phone:(+94) 771117673
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
