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

PartitionState update with finished execution fails

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.1.4, 1.2.0
    • Runtime / Network
    • None

    Description

      If a partition state request is triggered for a producer that finishes before the request arrives, the execution is unregistered and the producer cannot be found. In this case the PartitionState returns null and the job fails.

      We need to check the producer location via the intermediate result partition in this case.

      See here: https://api.travis-ci.org/jobs/177668505/log.txt?deansi=true

      Attachments

        Issue Links

          is duplicated by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-3053 SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed
          supercedes

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-4131 Confusing error for out dated RequestPartitionState

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #2912

          Web Link GitHub Pull Request #2913

          Web Link GitHub Pull Request #2975

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: