You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/03 11:42:27 UTC
[jira] [Created] (FLINK-2958) StreamingJobGraphGenerator sets hard
coded number execution retry
Ufuk Celebi created FLINK-2958:
----------------------------------
Summary: StreamingJobGraphGenerator sets hard coded number execution retry
Key: FLINK-2958
URL: https://issues.apache.org/jira/browse/FLINK-2958
Project: Flink
Issue Type: Bug
Components: Distributed Runtime
Affects Versions: 0.10
Reporter: Ufuk Celebi
Assignee: Ufuk Celebi
Fix For: 0.10
In StreamingJobGraphGenerator:
{code}
private void configureExecutionRetries() {
int executionRetries = streamGraph.getExecutionConfig().getNumberOfExecutionRetries();
if (executionRetries != -1) {
jobGraph.setNumberOfExecutionRetries(executionRetries);
} else {
// if the user didn't configure anything, the number of retries is 0.
jobGraph.setNumberOfExecutionRetries(0);
}
}
{code}
This results in the default cluster-wide configuration to be ignored.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)