Great Suho On Jan 10, 2014 10:43 AM, "Lasantha Fernando" <[email protected]> wrote:
> Hi Suho, > > Mohan has already added a note to the doc. Thanks Mohan for adding to > docs.. :-) > > > On 10 January 2014 08:05, Sriskandarajah Suhothayan <[email protected]> wrote: > >> Lasantha please add this to the docs too. >> >> Suho >> On Jan 10, 2014 1:15 AM, "Lasantha Fernando" <[email protected]> wrote: >> >>> Hi, >>> >>> For the event builder to be active, the stream to which that builder is >>> publishing must be defined. Also, for WSO2 events, the incoming stream >>> definition also must be defined. >>> >>> You can go to the inactive event builders section in management console >>> where you can find a short message specifying the reason why the event >>> builder is inactive. Usually a similar message will be printed to console >>> as well. >>> >>> HTH, >>> Lasantha >>> >>> >>> On 10 January 2014 00:22, Chamila Wijayarathna <[email protected]> wrote: >>> >>>> Hi all, >>>> After changing "*org.wso2.log_analyzer.out*" stream I am not getting >>>> that exception. Thank you for helping. >>>> I added few eventBuilders and they have been shown as Inactive >>>> builders, what is the reason for that? >>>> >>>> Thank you. >>>> >>>> >>>> On Thu, Jan 9, 2014 at 11:54 PM, Lasantha Fernando >>>> <[email protected]>wrote: >>>> >>>>> Hi Chamila, >>>>> >>>>> Looking at the snippet pasted here, I cannot find any obvious issue in >>>>> your code. Can you point to the complete code for your client so I can dig >>>>> deeper? >>>>> >>>>> What are the values you pass for STREAM_NAME1 and VERSION1? >>>>> >>>>> Also, it seems the error is coming at data-bridge level before the >>>>> event hits the event builder. You can verify this by enabling tracing for >>>>> your InputEventAdaptor and EventBuilder, where you can see the actual >>>>> incoming event. Looking at the actual event received might help you find >>>>> where the issue is. >>>>> >>>>> Also as Manula has suggested, please check the *org.wso2.log_analyzer.out >>>>> stream *stream as well. >>>>> >>>>> Thanks, >>>>> Lasantha >>>>> >>>>> >>>>> On 9 January 2014 23:43, Manula Chathurika Thantriwatte < >>>>> [email protected]> wrote: >>>>> >>>>>> Hi, >>>>>> >>>>>> >>>>>> >>>>>> >>>>>> *Seems that org.wso2.log_analyzer.out stream have different stream >>>>>> definition. Please look into that. Thanks !* >>>>>> >>>>>> >>>>>> On Thu, Jan 9, 2014 at 11:07 PM, Chamila Wijayarathna < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> hello all, >>>>>>> I am trying to send some events to CEP in WSO2Event Format. >>>>>>> In my publisher I create a stream as follows. >>>>>>> >>>>>>> *streamId1 = dataPublisher.defineStream("{" +* >>>>>>> * " 'name':'" + STREAM_NAME1 + "'," +* >>>>>>> * " 'version':'" + VERSION1 + "'," +* >>>>>>> * " 'nickName': 'Statistics'," +* >>>>>>> * " 'description': 'Service statistics'," +* >>>>>>> * " 'metaData':[" +* >>>>>>> >>>>>>> * " {'name':'referer','type':'STRING'}" >>>>>>> +* >>>>>>> * " ]," +* >>>>>>> * " 'payloadData':[" +* >>>>>>> * " {'name':'SrcIp','type':'STRING'}," +* >>>>>>> * " {'name':'DestIp','type':'STRING'}," >>>>>>> +* >>>>>>> * " {'name':'size','type':'STRING'}," +* >>>>>>> * " >>>>>>> {'name':'timestamp','type':'STRING'}" +* >>>>>>> * " ]" +* >>>>>>> * "}");* >>>>>>> >>>>>>> Then I published some events using above stream as follows. >>>>>>> >>>>>>> Ob*ject[] meta = new Object[]{* >>>>>>> * "MetaData"* >>>>>>> * };* >>>>>>> *Object[] payload = new Object[]{* >>>>>>> * SrcIp,* >>>>>>> * DestIp,* >>>>>>> * size, // Unix timeStamp* >>>>>>> * "600" * >>>>>>> * };* >>>>>>> *Event statisticsEvent = new Event(streamId1, >>>>>>> System.currentTimeMillis(),* >>>>>>> * meta, >>>>>>> correlation, payload);* >>>>>>> * dataPublisher.publish(statisticsEvent);* >>>>>>> >>>>>>> I also created an event builder at CEP for above stream. It has the >>>>>>> following source view. >>>>>>> >>>>>>> *<?xml version="1.0" encoding="UTF-8"?>* >>>>>>> *<eventBuilder name="logg" statistics="disable" trace="disable" >>>>>>> xmlns="http://wso2.org/carbon/eventbuilder >>>>>>> <http://wso2.org/carbon/eventbuilder>">* >>>>>>> * <from eventAdaptorName="WSO2EventAdaptor" >>>>>>> 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="ref" type="string"/>* >>>>>>> * </property>* >>>>>>> * <property>* >>>>>>> * <from dataType="payload" name="SrcIp"/>* >>>>>>> * <to name="src" type="string"/>* >>>>>>> * </property>* >>>>>>> * <property>* >>>>>>> * <from dataType="payload" name="DestIp"/>* >>>>>>> * <to name="dest" 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>* >>>>>>> >>>>>>> When I run the publisher and send the events to CEP I'm getting >>>>>>> following exeption for each event. >>>>>>> >>>>>>> * ERROR - {QueueWorker} Wrongly formatted event sent for >>>>>>> carbon.super* >>>>>>> *org.wso2.carbon.databridge.core.exception.EventConversionException: >>>>>>> Error when converting MetaData of event bundle with events 36* >>>>>>> * at >>>>>>> org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.createEventList(ThriftEventConverter.java:126)* >>>>>>> * at >>>>>>> org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.toEventList(ThriftEventConverter.java:88)* >>>>>>> * at >>>>>>> org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:72)* >>>>>>> * at >>>>>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)* >>>>>>> * at >>>>>>> java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)* >>>>>>> * at java.util.concurrent.FutureTask.run(FutureTask.java:166)* >>>>>>> * 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:724)* >>>>>>> *Caused by: >>>>>>> org.wso2.carbon.databridge.core.exception.EventConversionException: No >>>>>>> StreamDefinition for streamId MetaData present in cache * >>>>>>> * at >>>>>>> org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.createEventList(ThriftEventConverter.java:112)* >>>>>>> * ... 8 more* >>>>>>> >>>>>>> What is the problem here? How can I solve this? >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> *Chamila Wijayarathna* >>>>>>> Engineering Intern, >>>>>>> WSO2 Inc. >>>>>>> >>>>>>> >>>>>>> _______________________________________________ >>>>>>> Dev mailing list >>>>>>> [email protected] >>>>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>>>> >>>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> Regards, >>>>>> Manula Chathurika Thantriwatte >>>>>> Software Engineer >>>>>> WSO2 Inc. : http://wso2.com >>>>>> lean . enterprise . middleware >>>>>> >>>>>> email : [email protected] / [email protected] >>>>>> phone : +94 772492511 >>>>>> blog : http://manulachathurika.blogspot.com/ >>>>>> >>>>>> >>>>>> >>>>>> >>>>>> _______________________________________________ >>>>>> 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 >>> >>> > > > -- > *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
