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
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 | 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>*
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
