Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2958

StreamingJobGraphGenerator sets hard coded number execution retry

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.0
    • 0.10.0, 1.0.0
    • Runtime / Coordination
    • None

    Description

      In StreamingJobGraphGenerator:

      	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);
      		}
      	}
      

      This results in the default cluster-wide configuration to be ignored.

      Attachments

        Activity

          People

            uce Ufuk Celebi
            uce Ufuk Celebi
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: