flink状态查看工具

[casel.chen]

我有一个flink sql写的数据实时同步作业，从mysql binlog cdc消费发到mongodb，仅此而已，没有lookup，也没有join。
查看checkpoint页显示状态有17MB，checkpoint耗时要2s。
想知道为什么状态会如此之大，有没有状态查看工具看看里面到底存了什么信息?

[Paul Lam]

可以使用 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 <[hidden email]> 写道：
>
> 我有一个flink sql写的数据实时同步作业，从mysql binlog cdc消费发到mongodb，仅此而已，没有lookup，也没有join。
> 查看checkpoint页显示状态有17MB，checkpoint耗时要2s。
> 想知道为什么状态会如此之大，有没有状态查看工具看看里面到底存了什么信息?