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

Request finished partition state fails due to referential equality comparison

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.5.0, 1.6.0
    • Fix Version/s: 1.5.0
    • Labels:
      None

      Description

      The execution of batch jobs can fail because in some cases we cannot retrieve the partition state. The problem seems to be that we use referential equality in JobMaster.java:619 when requesting the state of a finished result partition. This, of course, always fails with a PartitionProducerDisposedException because we should use the proper equals method for the comparison of the ResultPartitionID.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                till.rohrmann Till Rohrmann
                Reporter:
                till.rohrmann Till Rohrmann
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: