We should assign FLINK-2066 to Nuno. :) Regards, Chiwan Park
> On Jun 29, 2015, at 1:21 PM, Márton Balassi <balassi.mar...@gmail.com> wrote: > > 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. >>
