Re: Check-pointing configuration

2016-08-29 Thread Bhupesh Chawda
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 wrote: > Hi! > > R

Re: Check-pointing configuration

2016-08-29 Thread 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 wr

Check-pointing configuration

2016-08-28 Thread 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. ~