Sunday 15 February 2015

event table delete operation exception in wso2 cep 3.1.0 -



event table delete operation exception in wso2 cep 3.1.0 -

i learning utilize event table in cep , there mistake.

class="snippet-code-html lang-html prettyprint-override">from streaminstance[action contains 'add']#window.length(1) select * insert streaminstancetable; streaminstance[action contains 'delete'] delete streaminstancetable on streaminstancetable.streamname == streaminstance.streamname;

when delete info streaminstancetable,if take conditions (on) wrong, if not status right.

class="snippet-code-css lang-css prettyprint-override">[2014-10-23 17:40:28,674] info - {redislistener} recving mesage:{"log": "streaminstancetemplatename","streamname": "stream1","modulecount" : "4","ip": "127.0.0.1","pid": "1001","from": "container","gid": "gid100","action":"delete"} [2014-10-23 17:40:28,678] error - {eventjunction} error while dispatching events java.lang.arrayindexoutofboundsexception: -1 @ org.wso2.siddhi.core.event.stateevent.getstreamevent(stateevent.java:51) @ org.wso2.siddhi.core.executor.expression.variableexpressionexecutor.execute(variableexpressionexecutor.java:151) @ org.wso2.siddhi.core.executor.conditon.compare.compareconditionexecutor.execute(compareconditionexecutor.java:48) @ org.wso2.siddhi.core.table.inmemoryeventtable.delete(inmemoryeventtable.java:82) @ org.wso2.siddhi.core.query.output.callback.deletetablecallback.send(deletetablecallback.java:36) @ org.wso2.siddhi.core.query.output.ratelimit.outputratemanager.sendtocallbacks(outputratemanager.java:38) @ org.wso2.siddhi.core.query.output.ratelimit.passthroughoutputratemanager.send(passthroughoutputratemanager.java:26) @ org.wso2.siddhi.core.query.selector.queryselector.process(queryselector.java:221) @ org.wso2.siddhi.core.query.processor.handler.simplehandlerprocessor.processhandler(simplehandlerprocessor.java:149) @ org.wso2.siddhi.core.query.processor.handler.simplehandlerprocessor.receive(simplehandlerprocessor.java:77) @ org.wso2.siddhi.core.stream.streamjunction.send(streamjunction.java:45) @ org.wso2.siddhi.core.stream.input.inputhandler.send(inputhandler.java:41) @ org.wso2.carbon.event.processor.core.internal.listener.siddhiinputeventdispatcher.sendevent(siddhiinputeventdispatcher.java:107) @ org.wso2.carbon.event.processor.core.internal.listener.siddhiinputeventdispatcher.consumeeventdata(siddhiinputeventdispatcher.jav a:95)

can seek below query, there seems known issue (don't utilize stream definition name prefix)

from streaminstance[action contains 'delete'] delete streaminstancetable on streaminstancetable.streamname == streamname;

table exception wso2 cep

No comments:

Post a Comment