Hey, Thanks for picking up the issue. This value can be specified as "execution-retries.delay" in the flink-conf.yaml. Hence you can check the associated value in the ConfigConstants [1] and track the way it is used. It is passed a couple of times, but is ultimately used in ExecutionGraph. [2]
[1] https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java#L54 [2] https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java#L714 Best, Marton On Sun, Jun 28, 2015 at 1:56 PM, Nuno Santos <n.marques.san...@gmail.com> wrote: > Hi guys. > > I've been digging around the docs for the last few days and I am now ready > to have a go at my first contribution. > > I chose FLINK-2066 <https://issues.apache.org/jira/browse/FLINK-2066> and > I > am looking for some guidance. > > I understand the change will be associated to the ExecutionConfig class, > which is reference by the Execution Environment. > > I made my way through the code to the LocalEnvironment and LocalExecutor. > > However, besides setters and getters, I do not see where the > numberOfExecutionRetries is used in the execution itself? > > Any pointers on where to look will be appreciated, I will continue to make > my way through the code to see what else I can find. > > Thanks, > Nuno. >
