Ufuk Celebi created FLINK-5114:
----------------------------------
Summary: PartitionState update with finished execution fails
Key: FLINK-5114
URL: https://issues.apache.org/jira/browse/FLINK-5114
Project: Flink
Issue Type: Bug
Components: Network
Reporter: Ufuk Celebi
Assignee: Ufuk Celebi
If a partition state request is triggered for a producer that finishes before
the request arrives, the execution is unregistered and the producer cannot be
found. In this case the PartitionState returns null and the job fails.
We need to check the producer location via the intermediate result partition in
this case.
See here: https://api.travis-ci.org/jobs/177668505/log.txt?deansi=true
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)