Hi,
running your job from within your IDE with no specific configuration
provided (like the Flink job examples provided by the Flink [1]) means that
you spin up a local Flink cluster (see MiniCluster [2]). This does not have
the web UI enabled by default. You could enable it by calling
`StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(config);`,
instead. Don't forget to add the `flink-runtime-web` dependency:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
Best,
Matthias
[1] https://github.com/apache/flink/tree/master/flink-examples
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/java/org/apache/flink/runtime/minicluster/MiniCluster.html
On Sat, Feb 20, 2021 at 4:07 AM Abu Bakar Siddiqur Rahman Rocky <
bakar121...@gmail.com> wrote:
> Hi,
>
> I read it:
> https://ci.apache.org/projects/flink/flink-docs-release-1.12/try-flink/local_installation.html
>
> I can run the code in the UI of Apache Flink that is in the bin file of
> Apache Flink. If I run a java code from intellij idea or eclipse, then how
> can I connect the code to apache flink UI?
>
> Thank you!
>
> On Fri, Feb 12, 2021 at 11:43 AM Matthias Pohl <matth...@ververica.com>
> wrote:
>
>> 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
>>
>
>
> --
> Regards,
> Abu Bakar Siddiqur Rahman
>
>
