(DEPRECATED) Apache Flink User Mailing List archive.

state.checkpoints.dir

Classic

List

Threaded

4 messages Options

bdas77

state.checkpoints.dir

Hello ,

Is there any hack to supply state.checkpoints.dir as argument or JVM parameter when running locally . I can change the source CheckpointCoordinator and make it work , trying to find if there is any shortcuts ??

Thank you

~ Biswajit

Thank you
~/Das

Hao Sun

Re: state.checkpoints.dir

We generate flink.conf on the fly, so we can use different values based on environment.

On Mon, Jan 22, 2018 at 12:53 PM Biswajit Das <[hidden email]> wrote:

Hello ,

Is there any hack to supply state.checkpoints.dir as argument or JVM parameter when running locally . I can change the source CheckpointCoordinator and make it work , trying to find if there is any shortcuts ??

Thank you
~ Biswajit

bdas77

Re: state.checkpoints.dir

Hi Hao ,

Thank you for reply . I was more of trying to find how do I manipulate when I run locally from IDE .

~ Biswajit

On Mon, Jan 22, 2018 at 12:56 PM, Hao Sun <[hidden email]> wrote:

We generate flink.conf on the fly, so we can use different values based on environment.

On Mon, Jan 22, 2018 at 12:53 PM Biswajit Das <[hidden email]> wrote:
Hello ,

Is there any hack to supply state.checkpoints.dir as argument or JVM parameter when running locally . I can change the source CheckpointCoordinator and make it work , trying to find if there is any shortcuts ??

Thank you
~ Biswajit

Thank you
~/Das

Chesnay Schepler

Re: state.checkpoints.dir

Something you could try is loading the GlobalConfiguration singleton before executing the job and setting
the parameter there.

On 23.01.2018 19:28, Biswajit Das wrote:

Hi Hao ,

Thank you for reply . I was more of trying to find how do I manipulate when I run locally from IDE .

~ Biswajit

On Mon, Jan 22, 2018 at 12:56 PM, Hao Sun <[hidden email]> wrote:

We generate flink.conf on the fly, so we can use different values based on environment.

On Mon, Jan 22, 2018 at 12:53 PM Biswajit Das <[hidden email]> wrote:

Hello ,

Is there any hack to supply state.checkpoints.dir as argument or JVM parameter when running locally . I can change the source CheckpointCoordinator and make it work , trying to find if there is any shortcuts ??

Thank you

~ Biswajit