Gyula Fora created FLINK-2419: --------------------------------- Summary: 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)