Sahil Takiar created HIVE-20280:
-----------------------------------
Summary: JobResultSerializer uses wrong registration id in
KyroMessageCodec
Key: HIVE-20280
URL: https://issues.apache.org/jira/browse/HIVE-20280
Project: Hive
Issue Type: Sub-task
Components: Spark
Reporter: Sahil Takiar
Assignee: Sahil Takiar
Inside {{KryoMessageCodec}} the code:
{code}
Kryo kryo = new Kryo();
int count = 0;
for (Class<?> klass : messages) {
kryo.register(klass, REG_ID_BASE + count);
count++;
}
kryo.register(BaseProtocol.JobResult.class, new JobResultSerializer(),
count);
{code}
Uses the wrong registration id for the {{JobResultSerializer}} it should be
{{REG_ID_BASE + count}} not {{count}}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)