[ https://issues.apache.org/jira/browse/FLINK-32865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lijie Wang updated FLINK-32865: ------------------------------- Fix Version/s: 1.19.0 > 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, 1.19.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)