>>>> The CEP library runs .... Correction; the CEP implemented using the CEP library runs .....
On Wed, Jul 19, 2017 at 10:08 AM, Sridhar Chellappa <flinken...@gmail.com> wrote: > A follow up question on this. I have a Complex Event processor implemented > using the CEP library (1.3.0). The CEP library runs a variety of rules that > are configured (enable/disable rule) VIA REST APIs. > > Now, if my application crashes and recovers (or is cancelled and > restarted), will my configuration(as to which rules are enabled) still > hold? or do I have to persist the info into a backend? > > > On Mon, Jul 10, 2017 at 7:36 PM, Nico Kruber <n...@data-artisans.com> > wrote: > >> Hi Aftab, >> looks like what you want is either an externalized checkpoint with >> RETAIN_ON_CANCELLATION mode [1] or a savepoint [2]. >> >> Ordinary checkpoints are deleted when the job is cancelled and only serve >> as a >> fault tolerance layer in case something goes wrong, i.e. machines fail, so >> that the job can be restarted automatically based on the restart policy. >> >> >> Nico >> >> [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/ >> checkpoints.html >> <https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/checkpoints.html> >> [2] https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/ >> savepoints.html >> <https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/savepoints.html> >> >> On Monday, 10 July 2017 14:20:53 CEST Aftab Ansari wrote: >> > Hi, >> > I am new to flink. I am facing issue implementing checkpoint. >> > >> > checkpoint related code: >> > >> > long checkpointInterval = 5000; >> > >> > StreamExecutionEnvironment env = StreamUtils.getEnvironment(params); >> > //specify backend >> > //env.setStateBackend(new FsStateBackend("s3n://xxx/flink-state/"), >> true)); >> > env.setStateBackend(new >> > FsStateBackend("file:///Users/aftabansari/flink-state/", true)); >> > //enable checkpoint >> > env.enableCheckpointing(checkpointInterval, >> > CheckpointingMode.EXACTLY_ONCE); >> > env.getCheckpointConfig().setMinPauseBetweenCheckpoints(500); >> > >> > >> > When I run the code, I can see flink-state being written in my local >> > machine. but when I stop the job , wait for a few minutes and restart >> the >> > job, it does not pick up from the time it left but it starts from when I >> > started the job. >> > >> > Could you point out what i am doing wrong. I am testing it locally from >> > ideaIntellij. below is what i see from localhost. Any help would be >> > appreciated. Thanks >> > [image: Inline images 1] >> > Br, >> >> >
