The input event stream that is fed to the CEP is not available outside.
On Wed, Jun 18, 2014 at 12:28 PM, Mohanadarshan Vivekanandalingam < [email protected]> wrote: > Oh i see.. No issue we'll chat later.. > Hmm, Is it not reproducible in your local environment?? > > > On Wed, Jun 18, 2014 at 12:26 PM, Gayashan Amarasinghe <[email protected]> > wrote: > >> Hi Mohan, >> >> Thanks a lot. I'm having lunch at the moment. Shall we meet after lunch? >> Btw cep is deployed in an EC2 instance, so i'm not sure whether we can >> remote debug. :( >> >> Gayashan Amarasinghe >> (sent from mobile) >> On 18 Jun 2014 12:20, "Mohanadarshan Vivekanandalingam" <[email protected]> >> wrote: >> >>> 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 >>> >> > > > -- > *V. Mohanadarshan* > *Software Engineer,* > *Data Technologies Team,* > *WSO2, Inc. http://wso2.com <http://wso2.com> * > *lean.enterprise.middleware.* > > email: [email protected] > phone:(+94) 771117673 > -- 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
