Uploaded image for project: 'ZZZ-WSO2 Complex Event Processor'
  1. ZZZ-WSO2 Complex Event Processor
  2. CEP-532

when a siddhi quey using expired events, an exception is thrown

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Highest
    • Resolution: Fixed
    • Affects Version/s: 3.0.0-RC7
    • Fix Version/s: 3.0.0, 3.1.0
    • Component/s: Event Processor
    • Labels:
    • Environment:

      Operating System : Linux
      Java Version/Java VM :jdk1.6.0
      Packs : wso2cep-3.0.0 (RC7)
      DBMS: h2
      Browser : Firefox
      Setup : NON Clustered Environment

    • Severity:
      Blocker
    • Estimated Complexity:
      Advanced
    • Test cases added:
      No

      Description

      when a siddhi quey using expired events, an exception is thrown

      steps
      1.create a flow where email is the input adapter type and mysql as the output adapter
      2.add the below as the execution planners siddhi query
      define partition stockPrice by
      range price < 100 as 'SMALL',
      range price >= 100 and price <= 200 as 'MEDIUM',
      range price > 201 as 'LARGE' ;

      from inputStream[symbol contains "FB" or symbol contains "LNKD" or price >100.00]#window.time(1)
      select symbol,price,avg(price) as Average
      group by symbol
      insert into symbolOutputStream for expired-events
      partition by stockPrice;

      3.send an email
      Note: below exception was thrown
      [2013-10-02 09:35:06,713] ERROR -

      {EventJunction}

      Error while dispatching events
      org.wso2.carbon.event.output.adaptor.core.exception.OutputEventAdaptorEventProcessingException: There is no any data-source found called : WSO2_CARBON_DB2
      at org.wso2.carbon.event.output.adaptor.core.internal.CarbonOutputEventAdaptorService.publish(CarbonOutputEventAdaptorService.java:92)
      at org.wso2.carbon.event.formatter.core.config.EventFormatter.sendEventData(EventFormatter.java:151)
      at org.wso2.carbon.event.formatter.core.EventFormatterSender.sendEventData(EventFormatterSender.java:36)
      at org.wso2.carbon.event.processor.core.internal.listener.ExternalStreamConsumer.consumeEvents(ExternalStreamConsumer.java:43)
      at org.wso2.carbon.event.processor.core.internal.stream.EventJunction.dispatchEvents(EventJunction.java:88)
      at org.wso2.carbon.event.processor.core.internal.listener.SiddhiOutputStreamListener.receive(SiddhiOutputStreamListener.java:66)
      at org.wso2.siddhi.core.stream.output.StreamCallback.send(StreamCallback.java:83)
      at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:56)
      at org.wso2.siddhi.core.stream.StreamJunction.send(StreamJunction.java:45)
      at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:35)
      at org.wso2.siddhi.core.query.output.ratelimit.OutputRateManager.sendToCallBacks(OutputRateManager.java:38)
      at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateManager.send(PassThroughOutputRateManager.java:26)
      at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:224)
      at org.wso2.siddhi.core.query.processor.window.TimeWindowProcessor.run(TimeWindowProcessor.java:126)
      at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
      at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
      at java.util.concurrent.FutureTask.run(FutureTask.java:138)
      at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
      at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:206)
      at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
      at java.lang.Thread.run(Thread.java:662)
      Caused by: org.wso2.carbon.event.output.adaptor.core.exception.OutputEventAdaptorEventProcessingException: There is no any data-source found called : WSO2_CARBON_DB2
      at org.wso2.carbon.event.output.adaptor.mysql.MysqlEventAdaptorType.initializeDatabaseTableInfo(MysqlEventAdaptorType.java:264)
      at org.wso2.carbon.event.output.adaptor.mysql.MysqlEventAdaptorType.publish(MysqlEventAdaptorType.java:149)
      at org.wso2.carbon.event.output.adaptor.core.AbstractOutputEventAdaptor.publishCall(AbstractOutputEventAdaptor.java:123)
      at org.wso2.carbon.event.output.adaptor.core.internal.CarbonOutputEventAdaptorService.publish(CarbonOutputEventAdaptorService.java:89)
      ... 21 more

        Attachments

          Activity

            People

            • Assignee:
              lasantha@wso2.com Lasantha Fernando
              Reporter:
              shavantha@wso2.com Shavantha Weerasinghe
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: