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)
