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)