Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
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