[jira] [Created] (FLINK-3249) Wrong "unknown partition state/input gate" error messages

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

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)