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
