Hi Mohan,
Yes I only have the above mentioned execution plan configuration.

Event Builder -

*<?xml version="1.0" encoding="UTF-8"?>*
*<eventBuilder name="logger3" statistics="disable" trace="enable"
xmlns="http://wso2.org/carbon/eventbuilder
<http://wso2.org/carbon/eventbuilder>">*
*    <from eventAdaptorName="DefaultWSO2EventInputAdaptor"
eventAdaptorType="wso2event">*
*        <property
name="stream">org.wso2.log_analyzer.netflow.info1</property>*
*        <property name="version">1.0.0</property>*
*    </from>*
*    <mapping customMapping="enable" type="wso2event">*
*        <property>*
*            <from dataType="meta" name="referer"/>*
*            <to name="meta_referer" type="string"/>*
*        </property>*
*        <property>*
*            <from dataType="payload" name="SrcIp"/>*
*            <to name="SrcIp" type="string"/>*
*        </property>*
*        <property>*
*            <from dataType="payload" name="DestIp"/>*
*            <to name="DestIp" type="string"/>*
*        </property>*
*        <property>*
*            <from dataType="payload" name="size"/>*
*            <to name="size" type="string"/>*
*        </property>*
*        <property>*
*            <from dataType="payload" name="timestamp"/>*
*            <to name="timestamp" type="string"/>*
*        </property>*
*    </mapping>*
*    <to streamName="org.wso2.log_analyzer.out" version="1.0.0"/>*
*</eventBuilder>*

org.wso2.log_analyzer.netflow.info1 -

StreamDefinition{ streamId='org.wso2.log_analyzer.netflow.info1:1.0.0',
name='org.wso2.log_analyzer.netflow.info1', version='1.0.0',
nickName='Statistics', description='Service statistics', tags=null,
metaData=[Attribute{name='referer', type=STRING}], correlationData=null,
payloadData=[Attribute{name='SrcIp', type=STRING}, Attribute{name='DestIp',
type=STRING}, Attribute{name='size', type=STRING},
Attribute{name='timestamp', type=STRING}], }

out1 -

StreamDefinition{ streamId='out1:1.0.0', name='out1', version='1.0.0',
nickName='', description='', tags=null, metaData=null,
correlationData=null, payloadData=[Attribute{name='SrcIp', type=STRING},
Attribute{name='DestIp', type=STRING}], }

Thank You




On Sat, Jan 11, 2014 at 6:37 AM, Mohanadarshan Vivekanandalingam <
[email protected]> wrote:

> Have you properly removed the invalid configs and tried again..
> If yes then share the event builder of this config and 
> org.wso2.log_analyzer.netflow.info1
> stream definition
> then we can check what went wrong and let you know..
>
> Thanks,
> Mohan
>
>
> On Sat, Jan 11, 2014 at 12:45 AM, Chamila Wijayarathna 
> <[email protected]>wrote:
>
>> Hi Mohan,
>> I did the changes you suggested and below is the new configuration.
>>
>> *<?xml version="1.0" encoding="UTF-8"?>*
>> *<executionPlan name="log_analyzer_test" 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="info1" name="org.wso2.log_analyzer.netflow.info1"
>> version="1.0.0"/>*
>> *  </importedStreams>*
>> *  <queryExpressions><![CDATA[from info1*
>> *select SrcIp, DestIp*
>> *insert into out1;]]></queryExpressions>*
>> *  <exportedStreams>*
>> *    <stream name="out1" valueOf="out1" version="1.0.0"/>*
>>
>> But I am still getting the same error. I made the out1 stream using
>> "Create Execution Plan" after writing the query.
>>
>> Thank You.
>> *  </exportedStreams>*
>> *</executionPlan>*
>>
>>
>> On Fri, Jan 10, 2014 at 5:49 PM, Mohanadarshan Vivekanandalingam <
>> [email protected]> wrote:
>>
>>> Hi,
>>>
>>> On Fri, Jan 10, 2014 at 5:25 PM, Chamila Wijayarathna 
>>> <[email protected]>wrote:
>>>
>>>> Hello all,
>>>> I wrote a simple execution plan with following configuration.
>>>>
>>>> *<?xml version="1.0" encoding="UTF-8"?>*
>>>> *<executionPlan name="log_analyzer_test" statistics="enable"*
>>>> *  trace="enable" 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="info1" name="org.wso2.log_analyzer.netflow.info1"
>>>> version="1.0.0"/>*
>>>> *  </importedStreams>*
>>>> *  <queryExpressions><![CDATA[from info1*
>>>> *select SrcIp, DestIp*
>>>> *insert into out;]]></queryExpressions>*
>>>> *  <exportedStreams>*
>>>> *    <stream name="org.wso2.log_analyzer.netflow.info1"*
>>>> *      passthroughFlow="enable" valueOf="out" version="1.0.0"/>*
>>>> *  </exportedStreams>*
>>>> *</executionPlan>*
>>>>
>>>> When I deployed this execution plan, it went to inactive state and says
>>>> as reason "[Dependency: org.wso2.log_analyzer.netflow.info1:1.0.0]". I
>>>> have "org.wso2.log_analyzer.netflow.info1" event stream added already.
>>>> What is the reason for it to held in inactive state?
>>>>
>>>
>>> There is a config issue in the executionPlan, we are able to fix that
>>> after an offline chat..
>>> This due to unavailability of proper output stream..
>>>
>>> Thanks,
>>> Mohan
>>>
>>>
>>>> Thank You!
>>>> --
>>>> *Chamila Wijayarathna*
>>>> Engineering Intern,
>>>> WSO2 Inc.
>>>>
>>>>
>>>> _______________________________________________
>>>> 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
>>>
>>
>>
>>
>> --
>> *Chamila Wijayarathna*
>> Engineering Intern,
>> WSO2 Inc.
>>
>>
>
>
> --
> *V. Mohanadarshan*
> *Software Engineer,*
> *Data Technologies Team,*
> *WSO2, Inc. http://wso2.com <http://wso2.com> *
> *lean.enterprise.middleware.*
>
> email: [email protected]
> phone:(+94) 771117673
>



-- 
*Chamila Wijayarathna*
Engineering Intern,
WSO2 Inc.
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev

Reply via email to