Re: Default restart behavior with checkpointing

2016-12-06 Thread Maximilian Michels
Very good question! As the documentation mentions, the old way was to use `setNumberOfExecutionRerties` but it has been replaced by `setRestartStrategy`. If you don't configure anything, then your job will _not_ be restarted. However, if you have enabled checkpointing, then your application will b

Fwd: Default restart behavior with checkpointing

2016-12-05 Thread Rohit Agarwal
Hi, https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/fault_tolerance.html says: Number of retries: The setNumberOfExecutionRerties() method defines how many times the job is restarted after a failure. When checkpointing is activated, but this value is not explicitly set,