Hi Yifan, Besides reading job state, I would like to know what statebackend are you using? Can you give the configurations about state and checkpoint for your job? Maybe you can check these configuration items to confirm if they are correct first.
Best, Shammon FY On Wed, Sep 6, 2023 at 3:17 PM Hang Ruan <ruanhang1...@gmail.com> wrote: > Hi, Yifan. > > I think the document[1] means to let us convert the DataStream to the > Table[2]. Then we could handle the state with the Table API & SQL. > > Best, > Hang > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/libs/state_processor_api/ > [2] > https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/data_stream_api/#converting-between-datastream-and-table > > 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 >> >
