flink 加工 千万级 的表,在流式加工处理的时候,怎么避免 内存溢出啥的?[阿里云实时计算 Flink版]

就是一个源头表 大概 5KW,加工之后,写入另一个表。 分页处理? 或者 有其它 方法 ?感谢指教

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. dataStreamAPI的话,不要在map invoke类的方法中频繁的new对象(此答案整理自Flink CDC 社区)

  2. 消息队列 写入 批量消费 不就好了(此答案整理自Flink CDC 社区)