Hi Chamila, How many event builders do you have? > In your Execution Plan your are using the input stream as > "org.wso2.log_analyzer.netflow.info1" > , hence you should also have a Event Builder outputting > org.wso2.log_analyzer.netflow.info1 > > +1.. Yes, Please check on that.. I think better if we can have a chat tomorrow and resolve this.. If there are any documentations lack on this then we can fix that also..
Thanks, Mohan > In your case Event Builder is outputting org.wso2.log_analyzer.out. > Therefore use org.wso2.log_analyzer.out as the input stream in the > Execution plan. > > Regards > Suho > > On Saturday, January 11, 2014, Chamila Wijayarathna wrote: > >> 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>* >> < >> >> > > -- > > *S. Suhothayan * > Associate Technical Lead, > *WSO2 Inc. *http://wso2.com > * <http://wso2.com/>* > lean . enterprise . middleware > > > *cell: (+94) 779 756 757 <%28%2B94%29%20779%20756%20757> | blog: > http://suhothayan.blogspot.com/ <http://suhothayan.blogspot.com/>twitter: > http://twitter.com/suhothayan <http://twitter.com/suhothayan> | linked-in: > http://lk.linkedin.com/in/suhothayan <http://lk.linkedin.com/in/suhothayan>* > > > -- *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
