flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5114) PartitionState update with finished execution fails
Date Mon, 21 Nov 2016 15:25:59 GMT
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

View raw message