我们有集群分布式模式的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?
暂无答案!
目前还没有任何答案,快来回答吧!