我对 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) 增加线程数。
先感谢您。