You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "zlzhang0122 (Jira)" <ji...@apache.org> on 2022/05/13 13:36:00 UTC
[jira] [Created] (FLINK-27608) Flink may throw PartitionNotFound Exception if the downstream task reached Running state earlier than it's upstream task
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)