Re: Flink 1.9.2 why always checkpoint expired

2020-05-03 Thread Congxian Qiu
Hi >From the picture and the previous eamil. you use RocksDBStateBackend, and all the operators chained together, checkpoint timeout set to 2min. Do you have keyed state in your job (do you have `keyby` in your job)? I'll share some experience to find out the reason of checkpoint timeout problem

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.