flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams
Date Thu, 04 Aug 2016 16:52:20 GMT

    [ 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:

    @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

View raw message