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:13:00 UTC

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17760389#comment-17760389 ] 

Lijie Wang commented on FLINK-32865:
------------------------------------

Fixed via:
master(1.19):
5ce5c8142c8c360bc10804fa1e52b13a3376a50f
3fffed00df3234106464642f555275b846ff74b3

release-1.18:
83915d909dce3832ba2c3dbd9b1624715466aa2d
94ba97a13abc7e70a55d929fd5fdf85d52417639

> 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
>            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)