You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Esper v7.1.0启用入站线程池时出现数据丢失问题

Esper 7.1.0 启用入站线程池时的数据丢失问题

我在使用Esper 7.1.0版本开发时,碰到了一个棘手的问题:当开启入站线程池(ThreadPoolInbound)配置后,会出现数据丢失的异常行为。

下面是能复现这个问题的极简代码示例:

Configuration config = new Configuration();
// 开启并发处理的入站线程池
config.getEngineDefaults().getThreading().setThreadPoolInbound(true);

EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(config);

// 定义一个简单的对象数组事件模式
epService.getEPAdministrator().createEPL("create objectarray schema LogLine as (account_name string, value int)");

补充说明:在后续的事件发送与业务处理环节中(示例代码省略了事件推送部分),启用入站线程池后会出现部分LogLine事件无法被引擎正确接收或处理,最终导致数据丢失。

内容的提问来源于stack exchange,提问作者Taras

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.05.22 08:06:26