Wenlong Lyu created FLINK-4271:
----------------------------------
Summary: There is no way to set parallelism of operators such as
map and window produced by
Key: FLINK-4271
URL: https://issues.apache.org/jira/browse/FLINK-4271
Project: Flink
Issue Type: Bug
Components: DataStream API
Reporter: Wenlong Lyu
Currently, CoGroupStreams package the map/keyBy/window operators with a human
friendly interface, like:
dataStreamA.cogroup(streamB).where(...).equalsTo().window().apply(), both the
intermediate operators and final window operators can not be accessed by users,
and we cannot set attributes of the operators, which make co-group hard to use
in production environment.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
