Hi Yifan,

AFAIK, if you want to query a job’s state from outside Flink, you can use
Queryable State[1].
Hope this helps.

[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/queryable_state/

Xiangyu


Yifan He via user <user@flink.apache.org> 于2023年9月6日周三 13:10写道:

> Hi team,
>
> We are investigating why the checkpoint size of our FlinkSQL jobs keeps
> growing and we want to look into the checkpoint file to know what is
> causing the problem. I know we can use the state processor api to read the
> state of jobs using datastream api, but how can I read the state of jobs
> using table api & sql?
>
> Thanks,
> Yifan
>

Reply via email to