订阅一个每隔100ms发布一次agg数据的tick数据源，每次更新数据都会触发一次计算并持久化计算结果，但计算时间较长为500ms，那后续的tick数据进入时的计算数据库会怎样处理

请先 登录 后评论

最佳答案 2024-01-30 16:32

会排队处理。你可以用getStreamingStat().subWorkers观察一下queueDepth的大小。若一直降不下去，可以在流表侧设置过滤，分发到多个订阅者即多个线程来处理。

请先 登录 后评论
默认排序 时间排序

其它 0 个回答

  • 1 关注
  • 0 收藏，243 浏览
  • ACE 提出于 2024-01-24 16:16

相似问题