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 >
