Checkpoints are stored in some DFS storage. The location can be specified using state.checkpoints.dir configuration property [1]. You can access the state of a savepoint or checkpoint using the State Processor API [2].
Best, Matthias [1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html#directory-structure [2] https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html On Fri, Feb 12, 2021 at 5:35 PM Abu Bakar Siddiqur Rahman Rocky < bakar121...@gmail.com> wrote: > Thank you for your reply. > > Another Question: > After Checkpointing, we save our snapshot to a storage. How can we access > the storage? > > is this the source code: > https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java > > If it is not, could you please provide me the source code to access in the > storage where snapshots are saved? > > Thank you > > > > > On Fri, Feb 12, 2021 at 2:44 AM Matthias Pohl <matth...@ververica.com> > wrote: > >> Hi Abu Bakar Siddiqur Rahman, >> Have you had a look at the Flink documentation [1]? It provides >> step-by-step instructions on how to run a job (the Flink binaries provide >> example jobs under ./examples) using a local standalone cluster. This >> should also work on a Mac. You would just need to start the Flink cluster >> (./bin/start-cluster.sh) and submit a job using one of the example jars >> provided in the binaries (e.g. ./bin/flink run -d >> ./examples/streaming/WordCount.jar). You can check the job running in >> Flink's web UI being available under http://localhost:8081 if you use >> the default configuration provided by the Flink binaries. >> >> Best, >> Matthias >> >> [1] >> https://ci.apache.org/projects/flink/flink-docs-release-1.12/try-flink/local_installation.html >> >> On Thu, Feb 11, 2021 at 3:45 PM Abu Bakar Siddiqur Rahman Rocky < >> bakar121...@gmail.com> wrote: >> >>> Hi, >>> >>> Is there anyone who can inform me how I can connect a Java program to >>> Apache Flink (in mac)? >>> >>> Thank you! >>> >>> Regards, >>> Abu Bakar Siddiqur Rahman >>> >>> On Thu, Feb 11, 2021 at 4:26 AM Abu Bakar Siddiqur Rahman Rocky < >>> bakar121...@gmail.com> wrote: >>> >>>> Hi Chesnay, >>>> >>>> Could you please inform me that how can I connect a Java program to >>>> apache Flink (in mac)? >>>> >>>> Thank you! >>>> >>>> Regards, >>>> Abu Bakar Siddiqur Rahman >>>> >>>> On Wed, Feb 3, 2021, 3:06 AM Chesnay Schepler <ches...@apache.org> >>>> wrote: >>>> >>>>> Sure. >>>>> >>>>> >>>>> https://github.com/apache/flink/tree/master/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint >>>>> >>>>> >>>>> https://github.com/apache/flink/tree/master/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper >>>>> >>>>> https://github.com/apache/flink/tree/master/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper >>>>> >>>>> On 2/3/2021 3:08 AM, Abu Bakar Siddiqur Rahman Rocky wrote: >>>>> >>>>> Hi, >>>>> >>>>> Is there any source code for the checkpoints, snapshot and zookeeper >>>>> mechanism? >>>>> >>>>> Thank you >>>>> >>>>> On Mon, Feb 1, 2021 at 4:23 AM Chesnay Schepler <ches...@apache.org> >>>>> wrote: >>>>> >>>>>> Could you expand a bit on what you mean? Are you referring to >>>>>> *savepoints*? >>>>>> >>>>>> On 1/28/2021 3:24 PM, Abu Bakar Siddiqur Rahman Rocky wrote: >>>>>> >>>>>> Hi, >>>>>> >>>>>> Is there any library to use and remember the apache flink snapshot? >>>>>> >>>>>> Thank you >>>>>> >>>>>> -- >>>>>> Regards, >>>>>> Abu Bakar Siddiqur Rahman >>>>>> >>>>>> >>>>>> >>>>>> >>>>> >>>>> -- >>>>> Regards, >>>>> Abu Bakar Siddiqur Rahman >>>>> Graduate Research Student >>>>> Natural Language Processing Laboratory >>>>> Centro de Investigacion en Computacion >>>>> Instituto Politecnico Nacional, Mexico City >>>>> >>>>> >>>>> >>> >>> -- >>> Regards, >>> Abu Bakar Siddiqur Rahman >>> >>> > > -- > Regards, > Abu Bakar Siddiqur Rahman > > -- Matthias Pohl | Engineer Follow us @VervericaData Ververica <https://www.ververica.com/> -- Join Flink Forward <https://flink-forward.org/> - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Ververica GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Yip Park Tung Jason, Jinwei (Kevin) Zhang, Karl Anton Wehner
