You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/08/08 11:11:00 UTC

[jira] [Created] (FLINK-28871) Make DPP also works if batch shuffle mode is not ALL_BLOCKING

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)