Junrui Li created FLINK-30685:
---------------------------------
Summary: Support mark the transformations whose parallelism is
infected by the input transformation
Key: FLINK-30685
URL: https://issues.apache.org/jira/browse/FLINK-30685
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Reporter: Junrui Li
Fix For: 1.17.0
In order to chain operators together as much as possible, many downstream
operators will use the parallelism of upstream input operators in the table
planner.
If some operators need to have their own defined parallelism, the parallelism
will be explicitly set. Therefore, the operator that takes the parallelism of
the upstream operator as its own parallelism should be automatically derived by
the AdaptiveBatchScheduler.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
