[ https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645779#comment-14645779 ]
ASF GitHub Bot commented on FLINK-2419: --------------------------------------- Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/947#issuecomment-125894533 If you give a +1 @rmetzger I will merge this > 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)