Ufuk Celebi created FLINK-3249:
----------------------------------
Summary: Wrong "unknown partition state/input gate" error messages
Key: FLINK-3249
URL: https://issues.apache.org/jira/browse/FLINK-3249
Project: Flink
Issue Type: Improvement
Components: Distributed Runtime
Affects Versions: 0.10.1
Reporter: Ufuk Celebi
Priority: Minor
Fix For: 1.0.0
[~StephanEwen] reported an issue during restarts of jobs with low execution
retries. He ran into the following error messages thrown by `Task`:
{quote}
"Received unexpected partition state $partitionState for partition request.
This is a bug."
{quote}
{quote}
"Received partition state for unknown input gate $resultId. This is a bug.
{quote}
I think that these are wrong in concurrent cancelling cases and we need to add
checks for it.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
