Hi,

We had an offline chat and was able to resolve this issue by changing the
configurations so that both queries run on the same execution plan.
However, we were not able to find out the root cause of why the
configurations for separate execution plans did not work.

@Chamila, can you share the all the configurations related that gives the
error so that we can look into it further?

Thanks,
Lasantha


On 16 January 2014 13:06, Chamila Wijayarathna <[email protected]> wrote:

> Hi Lasantha,
>
> event Builder - This input stream is coming from another execution plan,
> that plan is working properly and doesn't give any error when I remove 
> *"notify_High"
> execution plan.*
>
> <?xml version="1.0" encoding="UTF-8"?>
> <eventBuilder name="currentsums_1.0.0_builder" statistics="disable"
>     trace="disable" xmlns="http://wso2.org/carbon/eventbuilder";>
>     <from eventAdaptorName="DefaultWSO2EventInputAdaptor"
> eventAdaptorType="wso2event">
>         <property name="stream">currentsums</property>
>         <property name="version">1.0.0</property>
>     </from>
>     <mapping customMapping="disable" type="wso2event"/>
>     <to streamName="currentsums" version="1.0.0"/>
> </eventBuilder>
>
> Console doesn't show any stack trace. It only shows
>
> [2014-01-16 11:14:50,295] ERROR - {EventJunction}  Error while dispatching
> events
> java.lang.ArrayIndexOutOfBoundsException
>
> for each incoming event.
> I already checked it with event tracer, it shows messages similar to
>
>
> 13:00:26,209 [-] [DataBridge-Core-pool-2-thread-9]  INFO TenantId=-1234 : 
> Event Processor : notify_High,currentsums:1.0.0 (sums), before processing
>
> [Event{streamId='currentsums', timeStamp=1389857426209, data=[10.100.11.12, 
> 1000], type=new}]
>
> So data part of the input stream is in the expected format.
>
> Thank You.
>
>
>
> On Thu, Jan 16, 2014 at 12:10 PM, Lasantha Fernando <[email protected]>wrote:
>
>> Hi Chamila,
>>
>> Can you post the event builder configuration as well?
>>
>> Also, if possible, please post the full stack trace of the error you get
>> as well. This would make it easier to get to the root cause of the issue..
>> :-)
>>
>> You can enable tracing and look how the event comes to the execution
>> plan. This might give you a clue as to what is going wrong.
>>
>> Thanks,
>> Lasantha
>>
>>
>>
>> On 16 January 2014 10:58, Chamila Wijayarathna <[email protected]> wrote:
>>
>>> Hello all,
>>> I'm trying to run following execution plan on CEP.
>>>
>>> *<?xml version="1.0" encoding="UTF-8"?>*
>>> *<executionPlan name="notify_High" statistics="disable" trace="disable"
>>> xmlns="http://wso2.org/carbon/eventprocessor
>>> <http://wso2.org/carbon/eventprocessor>">*
>>> *  <description/>*
>>> *  <siddhiConfiguration>*
>>> *    <property
>>> name="siddhi.persistence.snapshot.time.interval.minutes">0</property>*
>>> *    <property
>>> name="siddhi.enable.distributed.processing">false</property>*
>>> *  </siddhiConfiguration>*
>>> *  <importedStreams>*
>>> *    <stream as="sums" name="currentsums" version="1.0.0"/>*
>>> *  </importedStreams>*
>>> *  <queryExpressions><![CDATA[from sums[bandwidth>10000]*
>>> *select SrcIp*
>>> *insert into shouldNotify;]]></queryExpressions>*
>>> *  <exportedStreams>*
>>> *    <stream name="shouldNotify" passthroughFlow="enable"*
>>> *      valueOf="shouldNotify" version="1.0.0"/>*
>>> *  </exportedStreams>*
>>> *</executionPlan>*
>>>
>>> But when I'm sending events to CEP, it says that
>>>
>>> *ERROR - {EventJunction}  Error while dispatching events*
>>> *java.lang.ArrayIndexOutOfBoundsException*
>>>
>>> I have set both input stream and output stream properly.
>>>
>>> *currentsums - *
>>> StreamDefinition{ streamId='currentsums:1.0.0', name='currentsums',
>>> version='1.0.0', nickName='', description='', tags=null, metaData=null,
>>> correlationData=null, payloadData=[Attribute{name='SrcIp', type=STRING},
>>> Attribute{name='bandwidth', type=LONG}], }
>>>
>>> *shouldNotify - *
>>> StreamDefinition{ streamId='shouldNotify:1.0.0', name='shouldNotify',
>>> version='1.0.0', nickName='', description='', tags=null, metaData=null,
>>> correlationData=null, payloadData=[Attribute{name='SrcIp', type=STRING}], }
>>>
>>> What is the reason for this error?
>>>
>>> Thank You.
>>>
>>>
>>> --
>>> *Chamila Wijayarathna*
>>> Engineering Intern,
>>> WSO2 Inc.
>>>
>>>
>>> _______________________________________________
>>> Dev mailing list
>>> [email protected]
>>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>>
>>>
>>
>>
>> --
>> *Lasantha Fernando*
>> Software Engineer - Data Technologies Team
>> WSO2 Inc. http://wso2.com
>>
>> email: [email protected]
>> mobile: (+94) 71 5247551
>>
>
>
>
> --
> *Chamila Wijayarathna*
> Engineering Intern,
> WSO2 Inc.
>
>


-- 
*Lasantha Fernando*
Software Engineer - Data Technologies Team
WSO2 Inc. http://wso2.com

email: [email protected]
mobile: (+94) 71 5247551
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev

Reply via email to