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

Posted to issues@flink.apache.org by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/08/30 13:14:00 UTC

[jira] [Closed] (FLINK-32865) DynamicFilteringDataCollectorOperator can't chain with the upstream operator when the parallelism is inconsistent

     [ https://issues.apache.org/jira/browse/FLINK-32865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Lijie Wang closed FLINK-32865.
------------------------------
      Assignee: Lijie Wang
    Resolution: Fixed

> DynamicFilteringDataCollectorOperator can't chain with the upstream operator when the parallelism is inconsistent
> -----------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-32865
>                 URL: https://issues.apache.org/jira/browse/FLINK-32865
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Planner
>    Affects Versions: 1.16.2, 1.18.0, 1.17.1
>            Reporter: dalongliu
>            Assignee: Lijie Wang
>            Priority: Major
>             Fix For: 1.18.0
>
>         Attachments: image-2023-08-14-19-17-22-109.png
>
>
> !image-2023-08-14-19-17-22-109.png!
>  
> If the DynamicFilteringDataCollectorOperator parallelism is not consistent with the upstream operator, they can't chain together, this will the DynamicFilteringDataCollectorOperator to execute after the fact source, so the dpp won't work. Due to the operator parallelism being decided during runtime, so we should add scheduler dependency forcibly in compile phase.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)