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)