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

PartitionState update with finished execution fails

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.2.0, 1.1.4
    • Component/s: Network
    • Labels:
      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

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: