[
https://issues.apache.org/jira/browse/FLINK-28799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-28799.
--------------------------------
Resolution: Fixed
master (1.16): 4deaf6edc152d06488f8738386b6a8b7544fe5e9
> Hybrid shuffle can't schedule graph contains blocking edge
> ----------------------------------------------------------
>
> Key: FLINK-28799
> URL: https://issues.apache.org/jira/browse/FLINK-28799
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.16.0
> Reporter: Weijie Guo
> Assignee: Weijie Guo
> Priority: Critical
> Labels: pull-request-available
> Fix For: 1.16.0
>
>
> Based on TPC-DS test, we found that hybrid shuffle can't schedule graph
> contains blocking edge. The reason is that some batch operators will forcibly
> set the exchange mode to blocking, which breaks ALL_ EDGE_HYBRID‘s constraint
> makes the scheduling deadlock.
> We should think of a better way to support the scheduling the graph of all
> kinds of edges, including hybrid edge.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)