dalongliu created FLINK-32865: --------------------------------- Summary: 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.17.1, 1.16.2, 1.18.0 Reporter: dalongliu 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)