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
