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

Noob question

2021-11-13 Thread ZhangJian He
Hello, I am new to flink. I want to know if I can generate savepoint according to the consuming message numbers(in Pulsar/Kafka) Thanks for your help ZhangJian He