[
https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147486#comment-15147486
]
ASF GitHub Bot commented on FLINK-3327:
---------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1583#discussion_r52911198
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ---
@@ -225,22 +233,12 @@ public int getNumberOfExecutionRetries() {
* @return The delay of time in milliseconds the system will try to
re-execute failed tasks.
*/
public long getExecutionRetryDelay() {
- return executionRetryDelay;
- }
-
- /**
- * Sets the delay that failed tasks are re-executed. A value of zero
- * effectively disables fault tolerance. A value of {@code -1}
indicates that the system
- * default value (as defined in the configuration) should be used.
- *
- * @param executionRetryDelay The delay of time the system will wait to
re-execute failed tasks.
- */
- public void setExecutionRetryDelay(long executionRetryDelay){
- if (executionRetryDelay < -1) {
+ long retryDelay = executionConfig.getExecutionRetryDelay();
+ if (retryDelay < -1) {
--- End diff --
same as above
> Attach the ExecutionConfig to the JobGraph and make it accessible to the
> AbstractInvocable.
> -------------------------------------------------------------------------------------------
>
> Key: FLINK-3327
> URL: https://issues.apache.org/jira/browse/FLINK-3327
> Project: Flink
> Issue Type: Sub-task
> Components: TaskManager
> Reporter: Klou
> Assignee: Klou
> Fix For: 1.0.0
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
