0

我对 WSO2 CEP 有疑问。请建议或解决此问题。

环境如下。
1) CEP 版本为 2.1.0。
2) 使用 TimeBatch 窗口和模式查询。

from RootStream#window.timeBatch(10000)
insert into AvgOneStream avg(watt) as avgOne


from every one = AvgOneStream[avgOne >= 10] ->
     two = AvgTwoStream[avgTwo >= 220] ->
     three = AvgThreeStream[avgThree >= 440]
within 10000
insert into Stream one.avgOne as avgOne, two.avgTwo as avgTwo, three.avgThree as avgThree

问题如下。
1) 出现内存不足。
2) 增加线程数。

先感谢您。

4

1 回答 1

0

这是 CEP 版本 2.1.0 中时间窗口中的一个已知错误,之前在此处的 StackOverflow 上提到了一个修复程序。

在较新版本的 CEP(3.0.0 及更高版本)中,此问题已得到修复。

于 2014-06-16T02:19:45.150 回答