wso2 cep siddhi窗口和表连接不能与apachestorm一起使用

dgsult0t  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(403)

我已经使用wso2cepv4.1.0创建了带有storm支持的简单执行计划。但当我在锡德地使用窗口设施时,它会给出一些例外。使用storm也不可能将表与流连接起来。如何解决此问题?有别的选择吗。
执行计划

@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 storm查询计划时出错。执行计划:执行计划租户:-1234。部署查询时出错:@name('query1')@dist(parallel='8',execgroup='filtering')from inputstream#window.time(1秒)select id as id,param3 as param3 insert into outputstream parallelism对于window、join和pattern查询必须为1。

oxalkeyp

oxalkeyp1#

当查询包含窗口、联接或模式时,查询的并行度不能大于1。这是因为当状态分布在多个螺栓上时,这样的查询无法正确处理。
但是,如果使用分区,那么窗口和模式查询的并行度可以大于1,因为一旦分区,每个分区就成为一个独立的处理单元,可以在不同的螺栓上独立地执行。请参阅此示例以更好地了解此类分区查询。

相关问题