Re: Noob question

2021-11-15 Thread Caizhi Weng
Hi! Please make sure to always cc the user mailing list. Otherwise other people will not see your mail. Can the checkpoint be manual trigger too? No you can't. Checkpoint can only be triggered by time. This is one of the main difference between checkpoint and savepoint [1]. What's your use cas

Re: Noob question

2021-11-14 Thread Caizhi Weng
Hi! Flink currently does not have an automatic way to achieve this. However you can use an external system to monitor on Kafka metrics [1] (for example currently consumed offsets) and trigger savepoints when certain conditions are met. [1] https://nightlies.apache.org/flink/flink-docs-master/docs