[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644962#comment-14644962
]
ASF GitHub Bot commented on FLINK-2419:
---------------------------------------
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/947
[FLINK-2419] Add test for sinks after keyBy and groupBy
Adds a missing test for FLINK-2419
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/gyfora/flink sink-hotfix
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/947.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #947
----
----
> DataStream sinks lose key information
> -------------------------------------
>
> Key: FLINK-2419
> URL: https://issues.apache.org/jira/browse/FLINK-2419
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Reporter: Gyula Fora
> Assignee: Gyula Fora
> Priority: Blocker
> Fix For: 0.10
>
>
> If the user applies an addSink method after keyBy, the sink will not have the
> information of the key as the transform method is bypassed.
> This makes it impossible to use partitioned states with sinks.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
