Yun Gao created FLINK-28871:
-------------------------------
Summary: Make DPP also works if batch shuffle mode is not
ALL_BLOCKING
Key: FLINK-28871
URL: https://issues.apache.org/jira/browse/FLINK-28871
Project: Flink
Issue Type: Sub-task
Components: Table SQL / Planner
Affects Versions: 1.16.0
Reporter: Yun Gao
Fix For: 1.16.0
Currently dpp only works when all edges is blocking. Otherwise if the dynamic
filtering data collector is located in the same region with the fact source,
the fact source would not be started after the data collector task.
To fix this issue, we'll force the collector task's output edges to be
blocking.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
