Check-pointing configuration

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Check-pointing configuration

Bhupesh Chawda
Hi,

I have a question on enabling checkpointing for one of my Flink jobs. I
understand that I can call *enableCheckpointing* on the
*StreamExecutionEnvironment* to enable it.

In my case, I don't have access to the source code; Is there also an option
to enable it through configuration?

Thanks.
~ Bhupesh
Reply | Threaded
Open this post in threaded view
|

Re: Check-pointing configuration

Stephan Ewen
Hi!

Right now, you would have to activate it on the StreamExecutionEnvironment.
We did not at a global setting for that, because each job may choose
different settings (like checkpointing interval).

Can you intercept the job anywhere?

Stephan


On Mon, Aug 29, 2016 at 8:47 AM, Bhupesh Chawda <[hidden email]> wrote:

> Hi,
>
> I have a question on enabling checkpointing for one of my Flink jobs. I
> understand that I can call *enableCheckpointing* on the
> *StreamExecutionEnvironment* to enable it.
>
> In my case, I don't have access to the source code; Is there also an option
> to enable it through configuration?
>
> Thanks.
> ~ Bhupesh
>
Reply | Threaded
Open this post in threaded view
|

Re: Check-pointing configuration

Bhupesh Chawda-2
Thanks Stephan, for your reply.

I am actually trying to run Apache Samoa algorithm on a Flink runner. There
I have access to just the jar file that is created, and the
samoa-flink.properties file. No other access point.

~ Bhupesh

On Mon, Aug 29, 2016 at 2:33 PM, Stephan Ewen <[hidden email]> wrote:

> Hi!
>
> Right now, you would have to activate it on the StreamExecutionEnvironment.
> We did not at a global setting for that, because each job may choose
> different settings (like checkpointing interval).
>
> Can you intercept the job anywhere?
>
> Stephan
>
>
> On Mon, Aug 29, 2016 at 8:47 AM, Bhupesh Chawda <[hidden email]>
> wrote:
>
> > Hi,
> >
> > I have a question on enabling checkpointing for one of my Flink jobs. I
> > understand that I can call *enableCheckpointing* on the
> > *StreamExecutionEnvironment* to enable it.
> >
> > In my case, I don't have access to the source code; Is there also an
> option
> > to enable it through configuration?
> >
> > Thanks.
> > ~ Bhupesh
> >
>