[HIVE-20280] JobResultSerializer uses wrong registration id in KyroMessageCodec

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Spark
• Assignee: Sahil Takiar
• Reporter: Sahil Takiar
• Created: 31/Jul/18 14:58
• Updated: 31/Jul/18 14:58

Description

Inside KryoMessageCodec the 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);

Uses the wrong registration id for the JobResultSerializer it should be REG_ID_BASE + count not count