Hi All,
I have gone through the configurations with Gayashan and found there are no
issues with that.. After enabling tracer found-out Siddhi returns some null
events when using having clause as mentioned below.
Event{streamId='load15_high_hosts_toalert', timeStamp=1403082054008,
data=[1403082035, ip-XXXXXXX, 0.07, 0.11666666666666665, 0.13, 1, 3],
type=new}, Event{streamId='load15_high_hosts_toalert',
timeStamp=1403082054008, data=[1403082030, ip-XXXXXXX, 0.19999999999999998,
0.18666666666666668, 0.21333333333333335, 1, 3], type=new}, null, null]
Then find-out the root-cause and fixed it.. Create a jira in [1] and
attached the source patch..
[1] https://wso2.org/jira/browse/CEP-871
For the moment i have provided an temp patch to overcome this issue, will
fix it in next release..
Thanks,
Mohan
On Wed, Jun 18, 2014 at 1:04 PM, Gayashan Amarasinghe <[email protected]>
wrote:
> 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
>
--
*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
