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 >
