I am new to the flink environment and looking to analyze the triggering of checkpoints. I am looking to trigger non-periodic checkpoints such that checkpoint intervals are not of equal length, but not sure how can I do this in Flink.
My specific query is; (1) How can I trigger non-periodic checkpoints in Flink? I am looking to trigger first checkpoint say after 10 seconds, the next checkpoint at say 25 seconds, third at 45 seconds and so on. Can I define my own function which triggers non-periodic checkpoints and generates no-uniform checkpoint intervals? Thanks. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/