Hi Abdullah, You don't need to implement checkpointed functions for checkpointing to work - but you may lose state if you manage it manually.
If you have enabled checkpointing, you should see it with any application that is running. Make sure that the checkpointing interval is small enough so that you can see it and that the job is fully running. If you want to try out a different application, you can check out the AsyncIOExample [1]. [1] https://github.com/apache/flink/blob/328e51b44db76cdd71dfa533c96967cb742b8d53/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java#L52 On Wed, Mar 10, 2021 at 8:10 PM Abdullah bin Omar < abdullahbinoma...@gmail.com> wrote: > Hi, > > [1] speaks about enable checkpointing, and [2] speaks about checkpointed > function. Do we need both to see a triggered and completed > checkpoint (according to the pic) in the apache flink UI? > > Is there any complete code available for checkpointing so that we can run > and see the triggered and completed checkpoint (according to the pic)? > > > [1] > https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/checkpointing.html#java > [2] > https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/java/org/apache/flink/streaming/api/functions/source/SourceFunction.html > > > Thank you for your service! > >
