[jira] [Created] (FLINK-27608) Flink may throw PartitionNotFound Exception if the downstream task reached Running state earlier than it's upstream task

Fri, 13 May 2022 06:36:04 -0700 

zlzhang0122 created FLINK-27608:
-----------------------------------

             Summary: Flink may throw PartitionNotFound Exception if the 
downstream task reached Running state earlier than it's upstream task
                 Key: FLINK-27608
                 URL: https://issues.apache.org/jira/browse/FLINK-27608
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.14.2
            Reporter: zlzhang0122
             Fix For: 1.16.0


Flink streaming job deployment may throw PartitionNotFound Exception if the 
downstream task reached Running state earlier than its upstream task and after 
maximum backoff for partition requests passed.But the config of 
taskmanager.network.request-backoff.max is not eay to decide. Can we use a loop 
awaiting the upstream task partition be ready?

 



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to