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)