理论上mini-batch就可以优化回撤流。 目前是join没有支持mini-batch。
On Thu, Dec 16, 2021 at 5:12 PM casel.chen <[email protected]> wrote: > > 看了《Oceanus的实时流式计算实践与优化》https://jishuin.proginn.com/p/763bfbd5acbf > 想问一下社区是否有意实现这里说的回撤流优化功能呢？ > 实际业务很多数据是从mysql binlog cdc接入的，在回撤流上做计算是常见的场景，能否在flink sql中支持这些优化呢？ -- Best, Jingsong Lee
