[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408106#comment-15408106
]
ASF GitHub Bot commented on FLINK-4271:
---------------------------------------
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2305
@zentol I think that works only in theory. In practice, probably no user is
going to realize that this trick is possible (even if we put it into the
JavaDocs). It also seems pretty mean thing to force a user to do.
I am quite torn at the moment whether this is an incident to break the API
- I am leaning towards yes.
> There is no way to set parallelism of operators produced by CoGroupedStreams
> ----------------------------------------------------------------------------
>
> Key: FLINK-4271
> URL: https://issues.apache.org/jira/browse/FLINK-4271
> Project: Flink
> Issue Type: Bug
> Components: DataStream API
> Reporter: Wenlong Lyu
> Assignee: Jark Wu
>
> 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)
