Hi Nuno! Ultimately, the delay is a property of the ExecutionGraph. The ExecutionGraph is the data structure on the master (JobManager) that tracks the distributed execution.
The property is set in the method "JobManager.submitJob(...)", which is called when a new job is sent to the cluster. Hope that helps! Greetings, Stephan On Mon, Jun 29, 2015 at 9:46 AM, Till Rohrmann <trohrm...@apache.org> wrote: > Done > > On Mon, Jun 29, 2015 at 9:33 AM, Chiwan Park <chiwanp...@apache.org> > wrote: > > > 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. > > >> > > > > > > >
