WSO2 CEP Siddhi 窗口和表连接不适用于 Apache Storm

Question

我使用 WSO2 CEP v4.1.0 创建了简单的执行计划，支持风暴。但是当我在 Siddhi 中使用窗口设施时，它会给出一些例外。并且它也不可能使用风暴将表与流连接起来。我该如何解决这个问题？有没有其他选择。

执行计划

@Plan:name('ExecutionPlan')

@Import('InputStream:1.0.0')
define stream InputStream (id string, param1 int, param2 double, param3 string, param4 string, param5 string, param6 string, param7 string);

@Export('outputStream:1.0.0')
define stream OutputStream (id string, param3 string);

@From(eventtable = 'rdbms' , datasource.name = 'MYSQL' , table.name = 'cep') 
define table cepTable (id string, param1 int, param2 double, param3 string, param4 string, param5 string, param6 string, param7 string);

@name('query1') 
@dist(parallel='8', execGroup='Filtering')
from InputStream#window.time(1 sec)
select id as id, param3 as param3  
insert into OutputStream;

CEP 给出的错误

异常：指定的分布式查询无效，转换时出错 到 XML 风暴查询计划。执行计划：ExecutionPlan 租户：-1234。 部署查询时出错：@name('query1') @dist(parallel='8', execGroup='Filtering') from InputStream#window.time(1 sec) select id 作为 id，param3 as param3 插入到 OutputStream 并行必须是 1 用于窗口、连接和模式查询。

Answer 1

当查询包含窗口、连接或模式时，查询的并行度不能大于 1。这是因为当状态分布在多个螺栓上时，无法正确处理此类查询。

但是，如果您使用partitions，则窗口和模式查询的并行度可以大于 1，因为一旦分区，每个分区就会成为一个独立的处理单元，可以在不同的螺栓上独立执行。请参阅this sample 以更好地了解此类分区查询。