[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644666#comment-14644666
]
Robert Metzger commented on FLINK-2419:
---------------------------------------
I see that its tricky to implement a test for this, but its one of the main
features of Flink, so its worth the effort (in my opinion)
I don't have time to work on this right now.
I agree that opening a second issue is a good idea, because the commit is
actually fixing two bugs. With two separate issues, we can track the resolution
of the issues easier.
> 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)
