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