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
Hi,
Flink currently does not have explicit Api support for that, but is
definitely possible to do. In fact Gyula (cc-d) mocked up a prototype for a
similar problem some time ago.
The idea needs some refinement to properly support all the viable use cases
though and the streaming Api currently
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]
