wso2cep部署执行计划并触发风暴时出现异常

px9o7tmv  于 2021-06-21  发布在  Storm
关注(0)|答案(0)|浏览(278)

我们有集群分布式模式的wso2cep4.1.0和apachestorm。当流的执行计划已触发时,它不能作为拓扑部署到storm。当我编辑执行计划并按下“添加执行计划”按钮时,cep会弹出一个例外

Failed to add execution plan, Exception: Invalid distributed query specified, Error while converting to XML storm query plan. Execution plan: Some-plan Tenant: -1234. No corresponding stream imported for Siddhi stream : SomeTrigger

下面是可以重现这种情况的最简单的执行计划。

@Plan:name('Some-plan')
@Plan:description('description')
@Plan:statistics('true')
@Plan:trace('true')

@Export('OutputStream:1.0.0')
define stream outputStream (triggered_time long, desc string);

@IndexBy('entity_id')
define table MemoryTable (  entity_id string);

define trigger SomeTrigger at '0 0 0 * * ? *';

@query(name='trigger-query1')
from SomeTrigger
    delete MemoryTable
    on triggered_time  > 0
;

@query(name='trigger-query2')
from SomeTrigger
select
    triggered_time
    , str:concat('Time: ', time:dateFormat(triggered_time, 'yyyy-MM-dd HH:mm:ss')) as desc
insert into outputStream;

如何将带有触发器的siddhi执行计划部署到apachestorm?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题