Maximilian Michels created BEAM-7436:
----------------------------------------

             Summary: Use Beam coder for Flink's encoded key instead of falling 
back to Kryo
                 Key: BEAM-7436
                 URL: https://issues.apache.org/jira/browse/BEAM-7436
             Project: Beam
          Issue Type: Improvement
          Components: runner-flink
            Reporter: Maximilian Michels
            Assignee: Maximilian Michels


There is no need to use a {{GenericTypeInfo}} for the {{ByteBuffer}} instance 
we use to represent the encoded key. Instead of falling back to Flink's Kryo, 
we should include a simple byte array coder and populate the type information 
properly.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to