[FLINK-9406] Request finished partition state fails due to referential equality comparison

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.5.0, 1.6.0
• Fix Version/s: 1.5.0
• Component/s: Runtime / Coordination
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 22/May/18 10:30
• Updated: 22/May/18 23:53
• Resolved: 22/May/18 23:52

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.

Issue Links

• links to: GitHub Pull Request #6057