埃斯珀即使在使用输出速率限制器后也在投掷 oom

Question

我们正在 esper 中创建一个每小时上下文，并将 @hint 与输出速率限制器一起使用。但是在某些事件中，我们仍然内存不足。 XMX -12 克

在某些情况下，如果我们的压缩不良，则意味着，例如，我们获得了 6 GB 的数据，这些数据是非聚合的，因此结果证明是来自 esper 的不良压缩。

我还想限制 esper 的大小，因此如果我们在每小时上下文之前达到限制，我可以刷新压缩不良的这一大块数据。

这就像您点击每小时上下文或刷新输出数据的大小一样。

我的查询

private static final String HOURLY_CONTEXT =
"create context HourlyRollup start(0,*,*,*,*,0) end(59,*,*,*,*,59)";
private static final String HINT = "@Hint('enable_outputlimit_opt') ";
private static final String HOURLY_STATEMENT = HINT+
"context HourlyRollup "
+ "select count(*) as xcount,hourlyFloor(min(from_time)),a,b,c,d,e,f,"
+ "g,h,sum(h),sum(i),j,k,l,"
+ "m,n,y,o,p,q,r "
+ "from io.common.Bean where Dir in (-5,-3,0,1) "
+ "group by a,b,c,d,e,f,g,Direction,h,"
+ "i,j,k,l,m,l,n,o,p output all "+"when terminated";

Answer 1

确保您的查询是完全聚合的，否则 Esper 必须保留事件，因为 select 子句要求事件数据。当查询完全聚合时，Esper 仅保留聚合数据，这就是您想要的。

这未完全聚合：

select a, b, count(*) from Event group by a

这是更好且完全聚合的：

select a, b, count(*) from Event group by a, b

这方面的文档在这里。