[FLINK-3249] Wrong "unknown partition state/input gate" error messages

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Won't Do
• Affects Version/s: 0.10.1
• Component/s: Runtime / Coordination
• Assignee: Unassigned
• Reporter: Ufuk Celebi
• Created: 18/Jan/16 10:33
• Updated: 26/Feb/19 16:23
• Resolved: 26/Feb/19 16:23

Description

StephanEwen reported an issue during restarts of jobs with low execution retries. He ran into the following error messages thrown by `Task`:

"Received unexpected partition state $partitionState for partition request. This is a bug."

"Received partition state for unknown input gate $resultId. This is a bug.

I think that these are wrong in concurrent cancelling cases and we need to add checks for it.