You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/28 15:38:04 UTC

[jira] [Created] (FLINK-2419) DataStream sinks lose key information

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)