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)
