jianzhang.yjz created FLINK-24698:
-------------------------------------
Summary: Unified operator used in transformation
Key: FLINK-24698
URL: https://issues.apache.org/jira/browse/FLINK-24698
Project: Flink
Issue Type: Improvement
Components: API / DataStream
Reporter: jianzhang.yjz
Fix For: 1.15.0
I found that all _*Transformation*_ expect *_ReduceTransformation_* are passed
_*StreamOperatorFactory*_ to construct _*XxxTranformation*_(such as
*_OneInputTransformation_*). I think _*ReduceTransformation*_ should also be
unified here, instead of transforming in _*ReduceTransformationTranslator*_.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
