Re: Flink 1.9.2 why always checkpoint expired

2020-04-27 Thread qq
Hi Jiayi Liao. Thanks your replying. Add attachment . And can’t get any useful messages; > 2020年4月27日 12:40,Jiayi Liao 写道: > > <粘贴的图形-1.tiff>

Re: Flink 1.9.2 why always checkpoint expired

2020-04-27 Thread Congxian Qiu
Hi The image is not very clear. For RocksDBStateBackend, do you enable incremental checkpoint? Currently, checkpoint on TM side contains some steps: 1 barrier align 2 sync snapshot 3 async snapshot For expired checkpoint, could you please check the tasks in the first operator of the DAG to find o

Flink 1.9.2 why always checkpoint expired

2020-04-26 Thread qq
Hi all, Why my flink checkpoint always expired, I used RocksDB checkpoint, and I can’t get any useful messages for this. Could you help me ? Thanks very much.