可以使用 State Processor [1]。 [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/libs/state_processor_api/
Best, Paul Lam > 2021年5月26日 09:14，casel.chen <casel_c...@126.com> 写道： > > 我有一个flink sql写的数据实时同步作业，从mysql binlog cdc消费发到mongodb，仅此而已，没有lookup，也没有join。 > 查看checkpoint页显示状态有17MB，checkpoint耗时要2s。 > 想知道为什么状态会如此之大，有没有状态查看工具看看里面到底存了什么信息?
