You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hive.apache.org by "Sahil Takiar (JIRA)" <ji...@apache.org> on 2018/07/31 14:59:00 UTC

[jira] [Created] (HIVE-20280) JobResultSerializer uses wrong registration id in KyroMessageCodec

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)